ros/autocoder
1
0
Fork 0
mirror of https://github.com/leonvanzyl/autocoder.git synced 2026-02-02 07:23:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: update log prefix when batch agent moves between features

Browse Source 
The output reader was stamping every line with the primary feature ID
(e.g., [Feature #24]) even after the agent claimed a new feature in the
batch. Now parses feature_claim_and_get calls in the output stream and
switches the prefix to the newly claimed feature ID, so logs correctly
show [Feature #30] once the agent moves on.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Auto
2026-02-01 16:42:56 +02:00
parent 1607fc8175
commit 016eead8b4
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
parallel_orchestrator.py
View File

@@ -22,6 +22,7 @@ import asyncio
import atexit import atexit
import logging import logging
import os import os
import re
import signal import signal
import subprocess import subprocess
import sys import sys
@@ -1116,6 +1117,11 @@ class ParallelOrchestrator:
return True return True
# Pattern to detect when a batch agent claims a new feature
_CLAIM_FEATURE_PATTERN = re.compile(
r"feature_claim_and_get\b.*?['\"]?feature_id['\"]?\s*[:=]\s*(\d+)"
)
def _read_output( def _read_output(
self, self,
feature_id: int | None, feature_id: int | None,
@@ -1124,6 +1130,7 @@ class ParallelOrchestrator:
agent_type: Literal["coding", "testing"] = "coding", agent_type: Literal["coding", "testing"] = "coding",
): ):
"""Read output from subprocess and emit events.""" """Read output from subprocess and emit events."""
current_feature_id = feature_id
try: try:
if proc.stdout is None: if proc.stdout is None:
proc.wait() proc.wait()
@@ -1132,11 +1139,17 @@ class ParallelOrchestrator:
if abort.is_set(): if abort.is_set():
break break
line = line.rstrip() line = line.rstrip()
# Detect when a batch agent claims a new feature
claim_match = self._CLAIM_FEATURE_PATTERN.search(line)
if claim_match:
claimed_id = int(claim_match.group(1))
if claimed_id != current_feature_id:
current_feature_id = claimed_id
if self.on_output is not None: if self.on_output is not None:
self.on_output(feature_id or 0, line) self.on_output(current_feature_id or 0, line)
else: else:
# Both coding and testing agents now use [Feature #X] format # Both coding and testing agents now use [Feature #X] format
print(f"[Feature #{feature_id}] {line}", flush=True) print(f"[Feature #{current_feature_id}] {line}", flush=True)
proc.wait() proc.wait()
finally: finally:
# CRITICAL: Kill the process tree to clean up any child processes (e.g., Claude CLI) # CRITICAL: Kill the process tree to clean up any child processes (e.g., Claude CLI)