Changeset 1626:ddad87f713cc

Timestamp:

11/11/08 16:33:50 (2 months ago)

Author:

Nate Coraor <nate@bx.psu.edu>

branch:

default

Message:

Change state to running before thread handoff.

Files:

• lib/galaxy/jobs/runners/local.py (modified) (2 diffs)

lib/galaxy/jobs/runners/local.py

@@ -41 +41 @@
-                
-    def run_job( self, job_wrapper ):
-        job_wrapper.change_state( 'running' )
-        job_wrapper.set_runner( 'local:///', None )
-        stderr = stdout = command_line = ''
@@ -87 +86 @@
-    def put( self, job_wrapper ):
-        """Add a job to the queue (by job identifier)"""
+        # Change to queued state before handing to worker thread so the runner won't pick it up again
+        job_wrapper.change_state( 'running' )
-        self.queue.put( job_wrapper )
-