Skip to content

Commit 6a50b7f

Browse files
committed
task state change
1 parent 818bfb8 commit 6a50b7f

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/data_parse.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -464,7 +464,10 @@ def parse_debug_line(self, line):
464464
raise ValueError(f"task {task_id} state change: from RUNNING (2) to RUNNING (2)")
465465
elif "RETRIEVED (4) to RUNNING (2)" in line:
466466
print(f"Warning: task {task_id} state change: from RETRIEVED (4) to RUNNING (2)")
467-
task.set_when_running(timestamp)
467+
pass
468+
elif "RUNNING (2) to DONE (5)" in line:
469+
print(f"Warning: task {task_id} state change: from RUNNING (2) to DONE (5)")
470+
pass
468471
elif "RUNNING (2) to WAITING_RETRIEVAL (3)" in line: # as expected
469472
task.set_when_waiting_retrieval(timestamp)
470473
# update the coremap

0 commit comments

Comments
 (0)