From da011fbc571be759106c2bcaec3e64b1b0523a33 Mon Sep 17 00:00:00 2001
From: Ed_ <edwardgz@gmail.com>
Date: Sat, 7 Mar 2026 15:59:59 -0500
Subject: [PATCH] feat(conductor): Populate abort_events when spawning workers

---
 src/multi_agent_conductor.py        |  3 +++
 tests/test_conductor_abort_event.py | 32 +++++++++++++++++++++++++++++
 2 files changed, 35 insertions(+)
 create mode 100644 tests/test_conductor_abort_event.py

diff --git a/src/multi_agent_conductor.py b/src/multi_agent_conductor.py
index c0453be..4db39a8 100644
--- a/src/multi_agent_conductor.py
+++ b/src/multi_agent_conductor.py
@@ -211,6 +211,9 @@ class ConductorEngine:
       )
       context_files = ticket.context_requirements if ticket.context_requirements else None
       
+      # Initialize abort event before spawning
+      self._abort_events[ticket.id] = threading.Event()
+      
       spawned = self.pool.spawn(
        ticket.id,
        run_worker_lifecycle,
diff --git a/tests/test_conductor_abort_event.py b/tests/test_conductor_abort_event.py
new file mode 100644
index 0000000..c78cf98
--- /dev/null
+++ b/tests/test_conductor_abort_event.py
@@ -0,0 +1,32 @@
+import pytest
+from unittest.mock import MagicMock, patch
+from src.multi_agent_conductor import ConductorEngine
+from src.models import Ticket, Track
+import threading
+
+def test_conductor_abort_event_populated():
+ """
+ Test that ConductorEngine populates _abort_events when spawning a worker.
+ """
+ # 1. Mock WorkerPool.spawn to return a mock thread
+ with patch('src.multi_agent_conductor.WorkerPool.spawn') as mock_spawn:
+  mock_spawn.return_value = MagicMock(spec=threading.Thread)
+  
+  # 2. Mock ExecutionEngine.tick
+  with patch('src.multi_agent_conductor.ExecutionEngine.tick') as mock_tick:
+   ticket_id = "test-ticket"
+   ticket = Ticket(id=ticket_id, description="Test description", status="todo")
+   mock_tick.return_value = [ticket]
+   
+   mock_track = Track(id="test-track", description="Test Track", tickets=[ticket])
+   
+   # 3. Set auto_queue=True
+   mock_queue = MagicMock()
+   engine = ConductorEngine(track=mock_track, event_queue=mock_queue, auto_queue=True)
+   
+   # 4. Call ConductorEngine.run(max_ticks=1)
+   engine.run(max_ticks=1)
+   
+   # 5. Assert that self._abort_events has an entry for the ticket ID
+   assert ticket_id in engine._abort_events
+   assert isinstance(engine._abort_events[ticket_id], threading.Event)