acp_sdk.server.context module¶
- class acp_sdk.server.context.Context[source]¶
Bases:
object- __init__(*, session_id=None, executor, yield_queue, yield_resume_queue)[source]¶
- Parameters:
session_id (UUID | None)
executor (ThreadPoolExecutor)
yield_queue (Queue[Message | MessagePart | str | MessageAwaitRequest | BaseModel | dict[str | Any] | None | Exception])
yield_resume_queue (Queue[MessageAwaitResume | None])
- Return type:
None
- async yield_async(value)[source]¶
- Parameters:
value (Message | MessagePart | str | MessageAwaitRequest | BaseModel | dict[str | Any] | None | Exception)
- Return type:
MessageAwaitResume | None
- yield_sync(value)[source]¶
- Parameters:
value (Message | MessagePart | str | MessageAwaitRequest | BaseModel | dict[str | Any] | None | Exception)
- Return type:
MessageAwaitResume | None