INNER CODE UNIT · Python

execute

evalstate/fast-agent · src/fast_agent/a2a/server.py:258

    async def execute(self, context: RequestContext, event_queue: EventQueue) -> None:
        if not context.message or not context.task_id or not context.context_id:
            return

        task = asyncio.current_task()
        if task is not None:
            self._running_tasks[context.task_id] = task
        try:
            await self._execute(context, event_queue)
        finally:
            self._running_tasks.pop(context.task_id, None)

    async def _execute(self, context: RequestContext, event_queue: EventQueue) -> None:
        assert context.message is not None
        assert context.task_id is not None
        assert context.context_id is not None

        updater = TaskUpdater(

View source record →