abc/analysis_claude_code
1
0
Fork 0
mirror of https://github.com/shareAI-lab/analysis_claude_code.git synced 2026-09-21 12:53:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: harden subprocess output decoding across lessons

Browse Source
This commit is contained in:
Haoran
2026-08-26 01:05:16 +08:00
parent 3e17b98504
commit cce031e632
34 changed files with 178 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
agents/s01_agent_loop.py
View File

@@ -68,7 +68,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=os.getcwd(),
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

4
agents/s02_tool_use.py
View File

@@ -57,8 +57,8 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True,
encoding="utf-8", errors="replace", timeout=120)
capture_output=True, text=True, errors="replace",
timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s03_todo_write.py
View File

@@ -108,7 +108,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s04_subagent.py
View File

@@ -62,7 +62,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s05_skill_loading.py
View File

@@ -133,7 +133,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s06_context_compact.py
View File

@@ -150,7 +150,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s07_task_system.py
View File

@@ -140,7 +140,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

4
agents/s08_background_tasks.py
View File

@@ -74,7 +74,7 @@ class BackgroundManager:
try:
r = subprocess.run(
command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=300
capture_output=True, text=True, errors="replace", timeout=300
)
output = (r.stdout + r.stderr).strip()[:50000]
status = "completed"
@@ -130,7 +130,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:

2
agents/s09_agent_teams.py
View File

@@ -273,7 +273,7 @@ def _run_bash(command: str) -> str:
try:
r = subprocess.run(
command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120,
capture_output=True, text=True, errors="replace", timeout=120,
)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"

2
agents/s10_team_protocols.py
View File

@@ -314,7 +314,7 @@ def _run_bash(command: str) -> str:
try:
r = subprocess.run(
command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120,
capture_output=True, text=True, errors="replace", timeout=120,
)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"

2
agents/s11_autonomous_agents.py
View File

@@ -400,7 +400,7 @@ def _run_bash(command: str) -> str:
try:
r = subprocess.run(
command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120,
capture_output=True, text=True, errors="replace", timeout=120,
)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"

12
agents/s12_worktree_task_isolation.py
View File

@@ -63,7 +63,7 @@ def detect_repo_root(cwd: Path) -> Path | None:
["git", "rev-parse", "--show-toplevel"],
cwd=cwd,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=10,
)
if r.returncode != 0:
@@ -246,7 +246,7 @@ class WorktreeManager:
["git", "rev-parse", "--is-inside-work-tree"],
cwd=self.repo_root,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=10,
)
return r.returncode == 0
@@ -260,7 +260,7 @@ class WorktreeManager:
["git", *args],
cwd=self.repo_root,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=120,
)
if r.returncode != 0:
@@ -365,7 +365,7 @@ class WorktreeManager:
["git", "status", "--short", "--branch"],
cwd=path,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=60,
)
text = (r.stdout + r.stderr).strip()
@@ -389,7 +389,7 @@ class WorktreeManager:
shell=True,
cwd=path,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=300,
)
out = (r.stdout + r.stderr).strip()
@@ -498,7 +498,7 @@ def run_bash(command: str) -> str:
shell=True,
cwd=WORKDIR,
capture_output=True,
text=True,
text=True, errors="replace",
timeout=120,
)
out = (r.stdout + r.stderr).strip()

4
agents/s_full.py
View File

@@ -89,7 +89,7 @@ def run_bash(command: str) -> str:
return "Error: Dangerous command blocked"
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=120)
capture_output=True, text=True, errors="replace", timeout=120)
out = (r.stdout + r.stderr).strip()
return out[:50000] if out else "(no output)"
except subprocess.TimeoutExpired:
@@ -345,7 +345,7 @@ class BackgroundManager:
def _exec(self, tid: str, command: str, timeout: int):
try:
r = subprocess.run(command, shell=True, cwd=WORKDIR,
capture_output=True, text=True, timeout=timeout)
capture_output=True, text=True, errors="replace", timeout=timeout)
output = (r.stdout + r.stderr).strip()[:50000]
self.tasks[tid].update({"status": "completed", "result": output or "(no output)"})
except Exception as e: