bobseares-2/revenue-recovery-agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

a2a-source-edit: write agent.py

Browse Source
This commit is contained in:
a2a-cloud
2026-07-13 03:03:26 +00:00
parent 23d03e5285
commit af937a4e5c
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
agent.py
View File

@@ -1032,12 +1032,14 @@ async def _persist_text(ctx: RunContext[NoAuth], run_id: str, filename: str, tex
sha = hashlib.sha256(data).hexdigest()
artifact_uri: str | None = None
try:
grant = await ctx.workspace.request_access(files=[rel_path], mode=WorkspaceMode.READ_WRITE_OVERLAY, reason="persist redacted revenue recovery output", purpose="write revenue recovery artifact")
view = await ctx.workspace.request_access(files=[rel_path], mode=WorkspaceMode.READ_WRITE_OVERLAY, reason="persist redacted revenue recovery output", purpose="write revenue recovery artifact")
# The workspace API returns grants; open a view for concrete writes.
opened = await ctx.workspace.open_view(purpose="persist revenue recovery output", hints=[rel_path], max_files=1, mode=WorkspaceMode.READ_WRITE_OVERLAY, reason="write generated output under outputs/revenue-recovery")
await opened.write(rel_path, data)
_ = grant, view
view = await ctx.workspace.open_view(
purpose="persist revenue recovery output",
hints=[rel_path],
max_files=1,
mode=WorkspaceMode.READ_WRITE_OVERLAY,
reason="write generated output under outputs/revenue-recovery",
)
await view.write(rel_path, data)
except Exception as exc: # workspace may be unavailable in local smoke calls; artifact still persists.
await ctx.emit_event(AgentEvent(kind="workspace_write_warning", payload={"path": rel_path, "message": str(exc)[:300]}))
try: