Exclude start_distributed_test.py from pytest collection

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

pyproject.toml

@@ -132,7 +132,7 @@ markers = [
 env = [
   "EXO_TESTS=1"
 ]
-addopts = "-m 'not slow'"
+addopts = "-m 'not slow' --ignore=tests/start_distributed_test.py"
 filterwarnings = [
     "ignore:builtin type Swig:DeprecationWarning",
 ]

src/exo/worker/main.py

@@ -224,10 +224,16 @@ class Worker:
                         )
                     )
                 case Shutdown(runner_id=runner_id):
+                    supervisor = self.runners.pop(runner_id)
                     try:
                         with fail_after(3):
-                            await self.runners.pop(runner_id).start_task(task)
+                            await supervisor.start_task(task)
                     except TimeoutError:
+                        logger.warning(
+                            f"Runner {runner_id} did not respond to Shutdown within 3s, "
+                            f"forcefully terminating process"
+                        )
+                        supervisor.shutdown()
                         await self.event_sender.send(
                             TaskStatusUpdated(
                                 task_id=task.task_id, task_status=TaskStatus.TimedOut