INNER CODE UNIT · Python

_execute

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

    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(
            event_queue=event_queue,
            task_id=context.task_id,
            context_id=context.context_id,
        )

        lock = await self._context_lock(self._lock_key(context))
        saved_bearer_token = request_bearer_token.set(_bearer_token_from_call_context(context))
        saved_a2a_task = _set_current_task(
            updater,
            event_queue=event_queue,
            request_message=context.message,
        )

View source record →