Skip to content

Commit

Permalink
fix update_task_priority to operate on idle tasks
Browse files Browse the repository at this point in the history
  • Loading branch information
dsschult committed Oct 11, 2024
1 parent 700d8cc commit 956b110
Show file tree
Hide file tree
Showing 6 changed files with 4 additions and 243 deletions.
74 changes: 0 additions & 74 deletions iceprod/scheduled_tasks/removed_tasks.py

This file was deleted.

93 changes: 0 additions & 93 deletions iceprod/scheduled_tasks/reset_tasks.py

This file was deleted.

2 changes: 1 addition & 1 deletion iceprod/scheduled_tasks/update_task_priority.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down
1 change: 1 addition & 0 deletions iceprod/server/plugins/condor.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,7 @@ class JobStatus(enum.Enum):


RESET_REASONS = [
'_condor_stdout: (errno 2) No such file',
'sigterm',
'killed',
'transfer input files failure',
Expand Down
2 changes: 2 additions & 0 deletions iceprod/server/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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()
Expand Down
75 changes: 0 additions & 75 deletions tests/scheduled_tasks/reset_tasks_test.py

This file was deleted.

0 comments on commit 956b110

Please sign in to comment.