fix update_task_priority to operate on idle tasks (#386)

WIPACrepo · Oct 11, 2024 · c7bbe0e · c7bbe0e
1 parent 700d8cc
commit c7bbe0e
Show file tree

Hide file tree

Showing 6 changed files with 4 additions and 243 deletions.
diff --git a/iceprod/scheduled_tasks/removed_tasks.py b/iceprod/scheduled_tasks/removed_tasks.py
diff --git a/iceprod/scheduled_tasks/reset_tasks.py b/iceprod/scheduled_tasks/reset_tasks.py
diff --git a/iceprod/scheduled_tasks/update_task_priority.py b/iceprod/scheduled_tasks/update_task_priority.py
@@ -24,7 +24,7 @@ async def run(rest_client, dataset_id=None, debug=False):
     prio = Priority(rest_client)
     try:
         args = {
-            'status': 'waiting|queued|processing|reset',
+            'status': 'idle|waiting',
             'keys': 'task_id|depends|dataset_id',
         }
         if dataset_id:

diff --git a/iceprod/server/plugins/condor.py b/iceprod/server/plugins/condor.py
@@ -70,6 +70,7 @@ class JobStatus(enum.Enum):
 
 
 RESET_REASONS = [
+    '_condor_stdout: (errno 2) No such file',
     'sigterm',
     'killed',
     'transfer input files failure',

diff --git a/iceprod/server/server.py b/iceprod/server/server.py
@@ -12,6 +12,7 @@
 import os
 import sys
 
+from iceprod import __version__ as version_string
 from iceprod.core.logger import set_log_level
 from iceprod.server.config import IceProdConfig
 from iceprod.server.queue import Queue
@@ -34,6 +35,7 @@ def __init__(self, config_params=None, outfile=None, errfile=None):
         self.queue = Queue(self.cfg)
 
         set_log_level(self.cfg['logging']['level'])
+        logger.error('IceProd Server - version %s', version_string)
 
     async def rotate_logs(self):
         current_date = datetime.utcnow()

diff --git a/tests/scheduled_tasks/reset_tasks_test.py b/tests/scheduled_tasks/reset_tasks_test.py