Merge pull request #3085 from mvdbeek/fix_torque_ssh

[16.07] Finish job for Torque SSH/CLI runner
galaxyproject · Nov 14, 2016 · 7272702 · 7272702
2 parents ae3bdf3 + 61d2572
commit 7272702
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/galaxy/jobs/runners/cli.py b/lib/galaxy/jobs/runners/cli.py
@@ -154,13 +154,16 @@ def check_watched_items( self ):
                         ajs.job_wrapper.change_state( state )
             else:
                 if state != old_state:
-                    log.debug("(%s/%s) state change: %s" % ( id_tag, external_job_id, state ) )
+                    log.debug("(%s/%s) state change: from %s to %s" % ( id_tag, external_job_id, old_state, state ) )
                     ajs.job_wrapper.change_state( state )
                 if state == model.Job.states.RUNNING and not ajs.running:
                     ajs.running = True
                     ajs.job_wrapper.change_state( model.Job.states.RUNNING )
             ajs.old_state = state
-            new_watched.append( ajs )
+            if state == model.Job.states.OK:
+                self.work_queue.put( ( self.finish_job, ajs ) )
+            else:
+                new_watched.append( ajs )
         # Replace the watch list with the updated version
         self.watched = new_watched