skip repeat tasks in runner

2026-02-05 03:33:30 -05:00 · 2026-02-04 19:19:29 +00:00
1 changed files with 1 additions and 1 deletions
--- a/src/exo/worker/runner/runner.py
+++ b/src/exo/worker/runner/runner.py
@@ -120,7 +120,7 @@ def main(
    with task_receiver as tasks:
        for task in tasks:
            if task.task_id in seen:
-                logger.warning("repeat task - potential error")
+                continue
            seen.add(task.task_id)
            event_sender.send(
                TaskStatusUpdated(task_id=task.task_id, task_status=TaskStatus.Running)