We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b03d26e commit bf8a0beCopy full SHA for bf8a0be
examples/mem_scheduler/task_stop_rerun.py
@@ -25,9 +25,9 @@ def my_test_handler(messages: list[ScheduleMessageItem]):
25
task_id = str(msg.item_id)
26
file_path = tmp_dir / f"{task_id}.txt"
27
try:
28
- print(f"writing {file_path}...")
29
- file_path.write_text(f"Task {task_id} processed.\n")
30
sleep(5)
+ file_path.write_text(f"Task {task_id} processed.\n")
+ print(f"writing {file_path} done")
31
except Exception as e:
32
print(f"Failed to write {file_path}: {e}")
33
0 commit comments