diff --git a/nmdc_automation/workflow_automation/watch_nmdc.py b/nmdc_automation/workflow_automation/watch_nmdc.py index 0522b4c9..5a76d7eb 100644 --- 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()