Skip to content

fix(stirrup_agent): DSv4 GDPVal multi-node run fixes #1497

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
agronskiy wants to merge 6 commits into from
+7 −3
Closed

fix(stirrup_agent): DSv4 GDPVal multi-node run fixes #1497

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
aee1b37
fix(stirrup_agent): fall back to msg.reasoning when reasoning_content…
agronskiy May 22, 2026
ed0a1da
fix(stirrup_agent): surface pydantic ValidationError detail in failed…
agronskiy May 22, 2026
a894eac
fix(stirrup_agent): monkey-patch tool lookup via self._active_tools (…
agronskiy May 22, 2026
392a509
fix(stirrup_agent): coerce finish.paths string→list to bypass vLLM de…
agronskiy May 23, 2026
de712ae
fix(stirrup/gdpval): pass GDPVAL_REF_FILES_DIR as a Ray task param
agronskiy May 30, 2026
34f8a4f
Merge remote-tracking branch 'origin/main' into agronskiy/feat/gdpval…
agronskiy Jun 8, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 7 additions & 3 deletions responses_api_agents/stirrup_agent/app.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -315,6 +315,7 @@ async def _run_stirrup_agent(
exec_provider_class: Optional[str] = None,
exec_provider_kwargs: Optional[Dict[str, Any]] = None,
persist_deliverables_dir: Optional[str] = None,
ref_files_dir: Optional[str] = None,
task_id: Optional[str] = None,
rollout_index: Optional[int] = None,
is_gdpval: bool = False,
Expand Down Expand Up @@ -442,11 +443,13 @@ async def run_command(self, cmd: str, *, timeout: int = SHELL_TIMEOUT) -> Comman
# operators whose worker /tmp is tight.
input_files_dir: Optional[str] = None
if is_gdpval and reference_files and reference_file_urls:
import os as _os_ref

from responses_api_agents.stirrup_agent.tasks.gdpval import _download_reference_files

ref_root = _os_ref.environ.get("GDPVAL_REF_FILES_DIR")
# ref_files_dir is resolved on the server and passed in via params (not read
# from the worker's os.environ): a runtime_env Ray worker on a non-Ray model
# deployment (e.g. sglang) does not reliably inherit GDPVAL_REF_FILES_DIR, so
# the env-only read fell back to node-local /tmp and broke cross-node upload.
ref_root = ref_files_dir or os.environ.get("GDPVAL_REF_FILES_DIR")
if ref_root:
Path(ref_root).mkdir(parents=True, exist_ok=True)
input_files_dir = tempfile.mkdtemp(prefix="gdpval_ref_files_", dir=ref_root)
Expand Down Expand Up @@ -879,6 +882,7 @@ async def responses(self, body: NeMoGymResponseCreateParamsNonStreaming = Body()
"exec_provider_class": exec_provider_class,
"exec_provider_kwargs": exec_provider_kwargs,
"persist_deliverables_dir": self.config.persist_deliverables_dir,
"ref_files_dir": os.environ.get("GDPVAL_REF_FILES_DIR"),
"task_id": task_info.get("task_id"),
"rollout_index": (body.metadata or {}).get("_ng_rollout_index"),
"is_gdpval": self.config.task == "gdpval",
Expand Down
Loading