Update competitions/runner.py
Browse files- competitions/runner.py +8 -5
competitions/runner.py
CHANGED
|
@@ -241,11 +241,14 @@ class JobRunner:
|
|
| 241 |
for space in all_submissions:
|
| 242 |
if space["status"] in {SubmissionStatus.QUEUED.value, SubmissionStatus.PROCESSING.value}:
|
| 243 |
logger.info(f"Cleaning up space {space['space_id']} for submission {space['submission_id']}")
|
| 244 |
-
|
| 245 |
-
|
| 246 |
-
|
| 247 |
-
|
| 248 |
-
|
|
|
|
|
|
|
|
|
|
| 249 |
if space["status"] in {SubmissionStatus.QUEUED.value, SubmissionStatus.PROCESSING.value, SubmissionStatus.PROCESSING.value}:
|
| 250 |
ready_submissions_count += 1
|
| 251 |
if ready_submissions_count == 0:
|
|
|
|
| 241 |
for space in all_submissions:
|
| 242 |
if space["status"] in {SubmissionStatus.QUEUED.value, SubmissionStatus.PROCESSING.value}:
|
| 243 |
logger.info(f"Cleaning up space {space['space_id']} for submission {space['submission_id']}")
|
| 244 |
+
try:
|
| 245 |
+
space_cleaner.clean_space(
|
| 246 |
+
space["space_id"],
|
| 247 |
+
space["team_id"],
|
| 248 |
+
space["submission_id"],
|
| 249 |
+
)
|
| 250 |
+
except Exception as e:
|
| 251 |
+
logger.error(f"Cleaning up space {space['space_id']} failed: {str(e)}")
|
| 252 |
if space["status"] in {SubmissionStatus.QUEUED.value, SubmissionStatus.PROCESSING.value, SubmissionStatus.PROCESSING.value}:
|
| 253 |
ready_submissions_count += 1
|
| 254 |
if ready_submissions_count == 0:
|