From b9b40b79e05155b5ed361f67c1ee864b404eb02c Mon Sep 17 00:00:00 2001 From: Calvin Date: Sun, 14 Jan 2024 13:02:44 +0200 Subject: [PATCH] update queue sort --- arc/job/adapter.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/arc/job/adapter.py b/arc/job/adapter.py index 57eeb17c4d..f97e19e263 100644 --- a/arc/job/adapter.py +++ b/arc/job/adapter.py @@ -1360,7 +1360,10 @@ def troubleshoot_queue(self) -> bool: filtered_queues = {queue_name: walltime for queue_name, walltime in queues.items() if convert_to_hours(walltime) >= self.max_job_time} # Now we sort the queues by walltime, and choose the one with the longest walltime. - sorted_queues = sorted(filtered_queues.items(), key=lambda x: convert_to_hours(x[1]), reverse=True) + #sorted_queues = sorted(filtered_queues.items(), key=lambda x: convert_to_hours(x[1]), reverse=True) + # Sort queue time from shortest to longest + sorted_queues = sorted(filtered_queues.items(), key=lambda x: convert_to_hours(x[1]), reverse=False) + self.queue = sorted_queues[0][0] if self.queue not in self.attempted_queues: self.attempted_queues.append(self.queue)