diff --git a/lib/galaxy/jobs/runners/pulsar.py b/lib/galaxy/jobs/runners/pulsar.py
index a13935f403bc..fc195451bb23 100644
--- 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"]