api_24sea.datasignals.async_execution

Asynchronous execution for planned DataSignals requests.

Functions

execute_data_requests_async(→ List[pandas.DataFrame])	Execute a request plan with bounded asynchronous HTTP calls.
execute_write_request_async(→ Dict[str, Any])	Execute one asynchronous DataSignals write request.

Module Contents

async execute_data_requests_async(plan: api_24sea.datasignals.planning.DataRequestPlan, base_url: str, headers: Dict[str, str] | None, auth: httpx.BasicAuth | None, timeout: int, max_retries: int, force_cache_miss: bool, method: str) → List[pandas.DataFrame]

Execute a request plan with bounded asynchronous HTTP calls.

async execute_write_request_async(request: api_24sea.datasignals.writes.DatasignalWriteRequest, base_url: str, headers: Dict[str, str] | None, auth: httpx.BasicAuth | None, timeout: int, max_retries: int) → Dict[str, Any]

Execute one asynchronous DataSignals write request.

Parameters

requestDatasignalWriteRequest

Validated write request.

base_urlstr

Normalized DataSignals application base URL.

headersdict, optional

HTTP headers to send.

authhttpx.BasicAuth, optional

Authentication configured on the facade.

timeoutint

Request timeout in seconds.

max_retriesint

Maximum number of retries after an HTTP 502 response.

Returns

dict

Validated backend write result.