Function _parse_opencode_log

agents/opencode_adapter.py:339–499

Parse an OpenCode JSONL log file into an ATIF Trajectory.

(
    log_path: Path,
    model_name: str,
    agent_name: str,
    instruction: str | None = None,
)

            f"echo \"[{prefix}-loop] Run ${vp}_RUN starting (budget=${{{vp}_TIMEOUT}}s)\" | tee -a /logs/agent/{log_file}; "
            f"{vp}_RUN_START=$(date +%s); "
            f"timeout ${{{vp}_TIMEOUT}}s opencode --model {escaped_model} run --format=json {escaped_instruction} "
            f"2>&1 </dev/null | tee -a /logs/agent/{log_file}; "
            f"{vp}_RUN_DUR=$(( $(date +%s) - {vp}_RUN_START )); "
            f"echo \"[{prefix}-loop] opencode exited after ${{{vp}_RUN_DUR}}s\" | tee -a /logs/agent/{log_file}; "
            # Track fast failures (< 10s) to avoid spinning on broken setups
            f"if [ ${vp}_RUN_DUR -lt 10 ]; then {vp}_FAST_FAILS=$(({vp}_FAST_FAILS + 1)); else {vp}_FAST_FAILS=0; fi; "
            "while true; do "
            # Consecutive fast failures usually mean a transient broken setup
            # (locked db, API hiccup). Before giving up for good, cool down
            # once for 60s and retry with a fresh session; abort only if the
            # fast-fails come right back.
            f"  if [ ${vp}_FAST_FAILS -ge ${vp}_MAX_FAST_FAILS ]; then "
            f"    if [ ${vp}_COOLDOWN_USED -ge 1 ]; then "
            f"      echo \"[{prefix}-loop] ${{{vp}_FAST_FAILS}} consecutive fast failures (<10s) after cooldown, aborting\" | tee -a /logs/agent/{log_file}; "
            "      break; "
            "    fi; "
            f"    {vp}_COOLDOWN_USED=1; {vp}_FAST_FAILS=0; {vp}_RESUME=0; "
            f"    echo \"[{prefix}-loop] ${{{vp}_MAX_FAST_FAILS}} consecutive fast failures (<10s) — cooling down 60s, then retrying with a fresh session\" | tee -a /logs/agent/{log_file}; "
            "    sleep 60; "
            "  fi; "
            f"  {vp}_ELAPSED=$(( $(date +%s) - {vp}_START )); "
            f"  {vp}_REMAINING=$(( {vp}_TIMEOUT - {vp}_ELAPSED )); "
            f"  echo \"[{prefix}-loop] Elapsed: ${{{vp}_ELAPSED}}s, Remaining: ${{{vp}_REMAINING}}s\" | tee -a /logs/agent/{log_file}; "
            f"  if [ ${vp}_REMAINING -lt ${vp}_MIN_RESTART ]; then "
            f"    echo \"[{prefix}-loop] Less than ${{{vp}_MIN_RESTART}}s remaining, stopping restart loop\" | tee -a /logs/agent/{log_file}; "
            "    break; "
            "  fi; "
            f"  {vp}_RUN=$(({vp}_RUN + 1)); "
            # Resume the previous session (context preserved) when possible:
            # pull the newest sessionID out of this session's own JSON log.
            f"  {vp}_SID=''; "
            f"  if [ ${vp}_RESUME -eq 1 ]; then {vp}_SID=$(grep -o '\"sessionID\":\"[^\"]*\"' /logs/agent/{log_file} | tail -1 | cut -d'\"' -f4); fi; "
            f"  echo \"[{prefix}-loop] Run ${vp}_RUN starting (${{{vp}_REMAINING}}s remaining)\" | tee -a /logs/agent/{log_file}; "
            f"  {vp}_RUN_START=$(date +%s); "
            f"  if [ -n \"${vp}_SID\" ]; then "
            f"    echo \"[{prefix}-loop] Resuming session ${vp}_SID\" | tee -a /logs/agent/{log_file}; "
            f"    timeout ${{{vp}_REMAINING}}s opencode --model {escaped_model} run --format=json --session \"${vp}_SID\" {resume_message} "
            f"    2>&1 </dev/null | tee -a /logs/agent/{log_file}; "
            "  else "
            f"    timeout ${{{vp}_REMAINING}}s opencode --model {escaped_model} run --format=json {continue_instruction} "
            f"    2>&1 </dev/null | tee -a /logs/agent/{log_file}; "
            "  fi; "
            f"  {vp}_RUN_DUR=$(( $(date +%s) - {vp}_RUN_START )); "
            f"  echo \"[{prefix}-loop] opencode exited after ${{{vp}_RUN_DUR}}s\" | tee -a /logs/agent/{log_file}; "
            # A fast-failing resume likely means the stored session is bad
            # (locked db, corrupt state) — fall back to a fresh session.
            f"  if [ ${vp}_RUN_DUR -lt 10 ]; then "
            f"    {vp}_FAST_FAILS=$(({vp}_FAST_FAILS + 1)); "
            f"    if [ -n \"${vp}_SID\" ]; then {vp}_RESUME=0; echo \"[{prefix}-loop] Resume failed fast — next run starts a fresh session\" | tee -a /logs/agent/{log_file}; fi; "
            f"  else {vp}_FAST_FAILS=0; {vp}_RESUME=1; fi; "
            "done; "
            f"echo \"[{prefix}-loop] Finished after ${vp}_RUN runs\" | tee -a /logs/agent/{log_file}"
        )

    def _agent_env(self) -> dict[str, str]:
        env = self._resolve_api_key_env()
        env["OPENCODE_YOLO"] = "true"
        env["OPENCODE_DANGEROUSLY_SKIP_PERMISSIONS"] = "true"