...

jmchilton · Mar 9, 2020 · a1fca9e · a1fca9e
1 parent 7d3d3fa
commit a1fca9e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/galaxy/jobs/runners/pulsar.py b/lib/galaxy/jobs/runners/pulsar.py
@@ -268,6 +268,7 @@ def check_watched_item(self, job_state):
         return job_state
 
     def _update_job_state_for_status(self, job_state, pulsar_status, full_status=None):
+        log.info("in _update_job_state_for_status...")
         if pulsar_status == "complete":
             self.mark_as_finished(job_state)
             return None
@@ -844,6 +845,7 @@ def _monitor(self):
         self.client_manager.ensure_has_ack_consumers()
 
     def __async_update(self, full_status):
+        log.info("in __async_update")
         galaxy_job_id = None
         try:
             remote_job_id = full_status["job_id"]