Function _run_agent_background

demo/ai_scientists/web/app.py:446–505

(run: RunState)

def _run_agent_background(run: RunState) -> None:
    env = os.environ.copy()
    env["CS_DASHBOARD_NO_BROWSER"] = "1"
    src_dir = str(PROJECT_ROOT / "src")
    env["PYTHONPATH"] = src_dir + os.pathsep + env.get("PYTHONPATH", "")

    agent_cmd = f"bash {RUN_AGENT_SH} {run.yaml_path} --no_dashboard"
    if _CONDA_ENV:
        shell_cmd = f"conda run -n {_CONDA_ENV} --no-capture-output {agent_cmd}"
    else:
        shell_cmd = agent_cmd

    try:
        proc = subprocess.Popen(
            shell_cmd, shell=True, cwd=str(PROJECT_ROOT), env=env,
            stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
        )
        run.process = proc

        host_log_dir = HOST_OUTPUTS_DIR / run.task_name
        run.event_log_path = str(host_log_dir / "agent_events.log")
        run.workspace_output_dir = str(WORKSPACE_OUTPUTS_DIR / run.task_name)
        run.status = "running"

        stdout_lines: list[str] = []
        if proc.stdout:
            for raw_line in proc.stdout:
                stdout_lines.append(raw_line.decode("utf-8", errors="replace"))

        proc.wait()
        final_status, _ = _parse_events(run.event_log_path)

        if final_status == "completed":
            # Keep status as "running" while post-processing so the frontend
            # does not fetch results before artefacts are ready.
            run.status = "post_processing"
            try:
                _post_process(run)
            except Exception as post_exc:
                import traceback
                traceback.print_exc()
                print(f"[POST] Post-processing error: {post_exc}")
            # Mark completed only AFTER zip/pdf are built
            run.status = "completed"
        elif proc.returncode != 0:
            run.status = "failed"
            tail = "".join(stdout_lines[-20:]).strip()
            run.error = f"Agent exited with code {proc.returncode}.\n{tail}"
        else:
            if final_status == "running":
                run.status = "failed"
                run.error = "Agent exited without completing the workflow."
            else:
                run.status = "failed"
                tail = "".join(stdout_lines[-20:]).strip()
                run.error = f"Agent produced no output.\n{tail}" if tail else "Agent produced no output."

    except Exception as exc: