Skip to content

Commit ace1416

Browse files
committed
Two small fixes local server task queue
1 parent da9b315 commit ace1416

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

ibllib/pipes/local_server.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import ibllib.oneibl.registration as registration
1717

1818
_logger = logging.getLogger('ibllib')
19-
LARGE_TASKS = ['EphysVideoCompress', 'TrainingVideoCompress', 'SpikeSorting'] # 'EphysDLC', 'TrainingDLC',
19+
LARGE_TASKS = ['EphysVideoCompress', 'TrainingVideoCompress', 'SpikeSorting', 'EphysDLC'] # 'TrainingDLC',
2020

2121

2222
def _get_pipeline_class(session_path, one):
@@ -164,6 +164,9 @@ def job_runner(subjects_path, mode='all', lab=None, dry=False, one=None, count=5
164164
tasks = one.alyx.rest('tasks', 'list', status='Waiting',
165165
django=f'session__lab__name__in,{lab},name__in,{LARGE_TASKS}', no_cache=True)
166166

167+
# Order tasks by priority
168+
tasks = sorted(tasks, key=lambda d: d['priority'], reverse=True)
169+
167170
tasks_runner(subjects_path, tasks, one=one, count=count, time_out=3600, dry=dry)
168171

169172

0 commit comments

Comments
 (0)