(
task_id: str, event_type: str, data: Any = None, error: Any = None
)
| 19 | |
| 20 | |
| 21 | def emit_event( |
| 22 | task_id: str, event_type: str, data: Any = None, error: Any = None |
| 23 | ) -> dict[str, Any]: |
| 24 | return { |
| 25 | "event_type": event_type, |
| 26 | "task_id": task_id, |
| 27 | "timestamp": time.strftime("%Y-%m-%dT%H:%M:%S+00:00", time.gmtime()), |
| 28 | "data": data, |
| 29 | "error": error, |
| 30 | } |
| 31 | |
| 32 | |
| 33 | def tool_started_sse(task_id: str, ev: dict[str, Any]) -> str: |
no outgoing calls
no test coverage detected