fixed filter for unclaimed jobs

microbiomedata · Feb 7, 2024 · d4b9109 · d4b9109
1 parent 540a59a
commit d4b9109
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/nmdc_automation/workflow_automation/watch_nmdc.py b/nmdc_automation/workflow_automation/watch_nmdc.py
@@ -117,7 +117,10 @@ def refresh_remote_jobs(self):
         """
         Return a filtered list of nmdc jobs.
         """
-        filt = {"workflow.id": {"$in": self._ALLOWED}}
+        filt = {
+            "workflow.id": {"$in": self._ALLOWED},
+            "claims": {"$size": 0}
+        }
         logging.debug("Looking for jobs")
         jobs = self.runtime_api.list_jobs(filt=filt)
         logging.debug(f"Found {len(jobs)} jobs")