From 14c3101256f11d3e27cd41251cf1e0f6689f879d Mon Sep 17 00:00:00 2001 From: Teknium <127238744+teknium1@users.noreply.github.com> Date: Sun, 6 Sep 2026 12:09:49 -0700 Subject: [PATCH] merge main: notice rides the per-group unit (unit_id, n_here); drop the detached kwarg main removed --- tools/delegate_tool_dispatch.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tools/delegate_tool_dispatch.py b/tools/delegate_tool_dispatch.py index 5d41ba42b5..09f8a42da4 100644 --- a/tools/delegate_tool_dispatch.py +++ b/tools/delegate_tool_dispatch.py @@ -94,7 +94,7 @@ def _report_child_done(parent_agent, spinner_ref, entry, tag, task_labels, n_tas with _quiet("Spinner update_text failed: %s"): spinner_ref.update_text(f"🔀 {'[' + tag + '] ' if tag else ''}{remaining} task{'s' if remaining != 1 else ''} remaining") -def _run_children_parallel(batch: _Batch, results: list, *, honor_parent_interrupt: bool, detached: bool = False) -> None: +def _run_children_parallel(batch: _Batch, results: list, *, honor_parent_interrupt: bool) -> None: """Run the batch's children in parallel, appending entries to ``results`` (sorted by task_index on return, one completion line printed per child). Polls futures with a short ``wait()`` timeout instead of ``as_completed()`` so a wedged child cannot block the parent forever after an interrupt; on parent interrupt the still-pending @@ -157,7 +157,7 @@ def _execute_and_aggregate(batch: _Batch, *, honor_parent_interrupt: bool = True if len(batch.children) == 1: results.append(batch.run_child(*batch.children[0])) else: - _run_children_parallel(batch, results, honor_parent_interrupt=honor_parent_interrupt, detached=detached) + _run_children_parallel(batch, results, honor_parent_interrupt=honor_parent_interrupt) _finalize_child_results(results, batch.task_list, batch.children, batch.parent_agent) total_duration = round(time.monotonic() - batch.overall_start, 2)