more logging

microbiomedata · Nov 26, 2024 · 61f1896 · 61f1896
1 parent 9201c53
commit 61f1896
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/nmdc_automation/workflow_automation/watch_nmdc.py b/nmdc_automation/workflow_automation/watch_nmdc.py
@@ -325,6 +325,7 @@ def cycle(self):
         if not successful_jobs and not failed_jobs:
             logger.info("No finished jobs found.")
         for job in successful_jobs:
+            logger.info(f"Processing successful job: {job.opid}, {job.workflow_execution_id}")
             job_database = self.job_manager.process_successful_job(job)
             # sanity checks
             if not job_database.data_object_set:
@@ -354,6 +355,7 @@ def cycle(self):
             logging.info(f"Updated operation {job.opid} response id: {resp}")
 
         for job in failed_jobs:
+            logger.info(f"Processing failed job: {job.opid}, {job.workflow_execution_id}")
             self.job_manager.process_failed_job(job)
 
     def watch(self):