(task_id: str, ev: dict[str, Any])
| 31 | |
| 32 | |
| 33 | def tool_started_sse(task_id: str, ev: dict[str, Any]) -> str: |
| 34 | return sse_format( |
| 35 | emit_event( |
| 36 | task_id, |
| 37 | "progress_update_tool_action_started", |
| 38 | data={ |
| 39 | "args": [ |
| 40 | { |
| 41 | "id": ev["tool_id"], |
| 42 | "function": { |
| 43 | "name": ev["name"], |
| 44 | "arguments": ev.get("arguments"), |
| 45 | }, |
| 46 | } |
| 47 | ] |
| 48 | }, |
| 49 | ) |
| 50 | ) |
| 51 | |
| 52 | |
| 53 | def tool_completed_sse( |
no test coverage detected