refactor(kanban-cli): swarm — pack private graph-builder signature/call (defaults were unused)

This commit is contained in:
Teknium
2026-09-02 21:17:47 -07:00
parent edfbd77443
commit cf3e78316b

View File

@@ -125,20 +125,11 @@ def create_swarm(
activated = False
with kb.write_txn(conn):
created = _create_swarm_uncommitted(
conn,
goal=goal,
workers=workers,
verifier_assignee=verifier_assignee,
synthesizer_assignee=synthesizer_assignee,
root_title=root_title,
verifier_title=verifier_title,
synthesizer_title=synthesizer_title,
tenant=tenant,
created_by=created_by,
workspace_kind=workspace_kind,
workspace_path=workspace_path,
priority=priority,
idempotency_key=idempotency_key,
conn, goal=goal, workers=workers, verifier_assignee=verifier_assignee,
synthesizer_assignee=synthesizer_assignee, root_title=root_title,
verifier_title=verifier_title, synthesizer_title=synthesizer_title, tenant=tenant,
created_by=created_by, workspace_kind=workspace_kind, workspace_path=workspace_path,
priority=priority, idempotency_key=idempotency_key,
)
root = kb.get_task(conn, created.root_id)
if root is not None and root.status == "blocked":
@@ -172,21 +163,10 @@ def create_swarm(
def _create_swarm_uncommitted(
conn: sqlite3.Connection,
*,
goal: str,
workers: Iterable[SwarmWorkerSpec],
verifier_assignee: str,
synthesizer_assignee: str,
root_title: Optional[str] = None,
verifier_title: str = "Verify swarm outputs",
synthesizer_title: str = "Synthesize swarm outputs",
tenant: Optional[str] = None,
created_by: str = "swarm-orchestrator",
workspace_kind: str = "scratch",
workspace_path: Optional[str] = None,
priority: int = 0,
idempotency_key: Optional[str] = None,
conn: sqlite3.Connection, *, goal: str, workers: Iterable[SwarmWorkerSpec],
verifier_assignee: str, synthesizer_assignee: str, root_title: Optional[str],
verifier_title: str, synthesizer_title: str, tenant: Optional[str], created_by: str,
workspace_kind: str, workspace_path: Optional[str], priority: int, idempotency_key: Optional[str],
) -> SwarmCreated:
"""Create the swarm graph inside the caller's transaction: planning root
(``blocked`` until the caller activates it), parallel workers, a verifier