details: http://www.bx.psu.edu/hg/galaxy/rev/ddad87f713cc changeset: 1626:ddad87f713cc user: Nate Coraor <nate@bx.psu.edu> date: Tue Nov 11 16:33:50 2008 -0500 description: Change state to running before thread handoff. 1 file(s) affected in this change: lib/galaxy/jobs/runners/local.py diffs (20 lines): diff -r 82cf78640bc1 -r ddad87f713cc lib/galaxy/jobs/runners/local.py --- a/lib/galaxy/jobs/runners/local.py Tue Nov 11 16:20:12 2008 -0500 +++ b/lib/galaxy/jobs/runners/local.py Tue Nov 11 16:33:50 2008 -0500 @@ -40,7 +40,6 @@ log.exception( "Uncaught exception running job" ) def run_job( self, job_wrapper ): - job_wrapper.change_state( 'running' ) job_wrapper.set_runner( 'local:///', None ) stderr = stdout = command_line = '' # Prepare the job to run @@ -86,6 +85,8 @@ 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 ) def shutdown( self ):