update task queued/processing when doing cross-check

WIPACrepo · Jan 3, 2025 · 448aac5 · 448aac5
1 parent 2fc4b00
commit 448aac5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/iceprod/server/plugins/condor.py b/iceprod/server/plugins/condor.py
@@ -858,6 +858,8 @@ async def check(self):
                     reason = extra.get('HoldReason', 'Job has failed')
                     logger.info("job %s %s.%s removed from cross-check: %r", job_id, job.dataset_id, job.task_id, reason)
                     self.submitter.remove(job_id, reason=reason)
+                else:
+                    self.job_update(job)
 
         await self.check_history()
 

diff --git a/iceprod/server/states.py b/iceprod/server/states.py
@@ -40,7 +40,7 @@
     'idle': ['waiting', 'suspended'],
     'waiting': ['queued', 'idle', 'suspended'],
     'queued': ['processing', 'idle', 'waiting', 'suspended', 'failed', 'complete'],
-    'processing': ['idle', 'waiting', 'suspended', 'failed', 'complete'],
+    'processing': ['idle', 'waiting', 'queued', 'suspended', 'failed', 'complete'],
     'suspended': ['idle', 'waiting'],
     'failed': ['idle', 'waiting'],
     'complete': [],