fix: add missing cancel_sender param to test supervisor builder

Co-Authored-By: Claude Opus 4.6 <[email protected]>
This commit is contained in:
Alex Cheema
2026-02-16 11:11:30 -08:00
co-authored by Claude Opus 4.6
parent 4fa6d05651
commit e5a8f39db6
@@ -69,6 +69,7 @@ def _build_supervisor(
_ev_send, ev_recv = mp_channel[Event]()
task_sender, _task_recv = mp_channel[Task]()
cancel_sender, _cancel_recv = mp_channel[TaskId]()
runner_process = multiprocessing.Process(target=target, daemon=True)
heartbeat: Synchronized[int] = multiprocessing.Value("Q", 0)
@@ -80,6 +81,7 @@ def _build_supervisor(
_ev_recv=ev_recv,
_task_sender=task_sender,
_event_sender=event_sender.clone(),
_cancel_sender=cancel_sender,
_heartbeat=heartbeat,
)