api_24sea.datasignals.execution

Synchronous execution for planned DataSignals requests.

Functions

execute_data_requests(→ List[pandas.DataFrame])	Execute a request plan with blocking HTTP workers.
execute_write_request(→ Dict[str, Any])	Execute one blocking DataSignals write request.

Module Contents

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

Execute a request plan with blocking HTTP workers.

execute_write_request(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 blocking 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.