bobseares-2/production-proof-v116-high-utili-7255-2
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-19 20:06:15 +00:00
parent c1900dd854
commit cef659db45
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
agent.py
View File

@@ -166,13 +166,17 @@ class ProductionProofV116HighUtili72552(
) )
queue = [_triage_message(message, policy) for message in messages] queue = [_triage_message(message, policy) for message in messages]
queue.sort(key=lambda item: _priority_rank(item.priority)) queue.sort(key=lambda queue_entry: _priority_rank(queue_entry.priority))
urgent_count = 0
for queue_entry in queue:
if queue_entry.priority == "urgent":
urgent_count += 1
summary = _summary(queue) summary = _summary(queue)
report = { report = {
"generated_at": datetime.now(UTC).isoformat(), "generated_at": datetime.now(UTC).isoformat(),
"summary": summary, "summary": summary,
"approval_boundary": _approval_boundary(), "approval_boundary": _approval_boundary(),
"queue": [item.model_dump(mode="json") for item in queue], "queue": [queue_entry.model_dump(mode="json") for queue_entry in queue],
} }
report_bytes = json.dumps(report, indent=2, ensure_ascii=False).encode("utf-8") report_bytes = json.dumps(report, indent=2, ensure_ascii=False).encode("utf-8")
artifact = await ctx.write_artifact( artifact = await ctx.write_artifact(
@@ -194,7 +198,7 @@ class ProductionProofV116HighUtili72552(
input_hash=input_hash, input_hash=input_hash,
result_summary={ result_summary={
"message_count": len(queue), "message_count": len(queue),
"urgent_count": sum(1 for item in queue if item.priority == "urgent"), "urgent_count": urgent_count,
"artifact_name": artifact.name, "artifact_name": artifact.name,
}, },
) )
@@ -522,8 +526,8 @@ def _priority_rank(priority: str) -> int:
def _summary(queue: list[QueueItem]) -> str: def _summary(queue: list[QueueItem]) -> str:
counts: dict[str, int] = {} counts: dict[str, int] = {}
for item in queue: for queue_entry in queue:
counts[item.priority] = counts.get(item.priority, 0) + 1 counts[queue_entry.priority] = counts.get(queue_entry.priority, 0) + 1
parts = [f"{counts.get(name, 0)} {name}" for name in ["urgent", "high", "normal", "low"] if counts.get(name, 0)] parts = [f"{counts.get(name, 0)} {name}" for name in ["urgent", "high", "normal", "low"] if counts.get(name, 0)]
return f"Prioritized {len(queue)} people-inbox message(s): " + ", ".join(parts) + "." return f"Prioritized {len(queue)} people-inbox message(s): " + ", ".join(parts) + "."