acp_sdk.server.utils module

async acp_sdk.server.utils.async_request_with_retry(request_func, max_retries=5, backoff_factor=1)[source]
Parameters:

  • request_func (Callable[[AsyncClient], Coroutine[Any, Any, Response]])

  • max_retries (int)

  • backoff_factor (float)

Return type:

dict[str, Any]

acp_sdk.server.utils.encode_sse(model)[source]
Parameters:

model (BaseModel)

Return type:

str

async acp_sdk.server.utils.stream_sse(run_data, store, idx, *, ready=None)[source]
Parameters:

  • run_data (RunData)

  • store (Store[RunData])

  • idx (int)

  • ready (Event | None)

Return type:

AsyncGenerator[str]

async acp_sdk.server.utils.wait_util_stop(run_data, store, *, ready=None)[source]
Parameters:

  • run_data (RunData)

  • store (Store[RunData])

  • ready (Event | None)

Return type:

RunData

async acp_sdk.server.utils.watch_util_stop(run_data, store, *, ready=None)[source]
Parameters:

  • run_data (RunData)

  • store (Store[RunData])

  • ready (Event | None)

Return type:

AsyncGenerator[RunData]