acp_sdk.server.bundle module¶

class acp_sdk.server.bundle.RunBundle[source]¶

Bases: object

__init__(*, agent, run, input, history, executor)[source]¶

Parameters:

agent (Agent)
run (Run)
input (list[Message])
history (list[Message])
executor (ThreadPoolExecutor)

Return type:

None

async await_()[source]¶

Return type:: MessageAwaitResume

async cancel()[source]¶

Return type:: None

async emit(event)[source]¶

Parameters:: event (RunCreatedEvent | RunInProgressEvent | MessageCreatedEvent | ArtifactEvent | MessagePartEvent | MessageCompletedEvent | RunAwaitingEvent | GenericEvent | RunCancelledEvent | RunFailedEvent | RunCompletedEvent)
Return type:: None

async join()[source]¶

Return type:: None

async resume(resume)[source]¶

Parameters:: resume (MessageAwaitResume)
Return type:: None

async stream()[source]¶

Return type:: AsyncGenerator[RunCreatedEvent | RunInProgressEvent | MessageCreatedEvent | ArtifactEvent | MessagePartEvent | MessageCompletedEvent | RunAwaitingEvent | GenericEvent | RunCancelledEvent | RunFailedEvent | RunCompletedEvent]