fix mis-handled claim_jobs

microbiomedata · Nov 25, 2024 · c7797a4 · c7797a4
1 parent 2aec24f
commit c7797a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nmdc_automation/workflow_automation/watch_nmdc.py b/nmdc_automation/workflow_automation/watch_nmdc.py
@@ -367,7 +367,7 @@ def claim_jobs(self, unclaimed_jobs: List[WorkflowJob] = None) -> None:
         for job in unclaimed_jobs:
             logger.info(f"Claiming job {job.workflow.nmdc_jobid}")
             claim = self.runtime_api_handler.claim_job(job.workflow.nmdc_jobid)
-            opid = claim["detail"]["id"]
+            opid = claim["id"]
             new_job = self.job_manager.prepare_and_cache_new_job(job, opid)
             if new_job:
                 new_job.job.submit_job()