core.requester

Requester object to make HTTP requests to the Jobmon Flask services.

Attributes

logger

Classes

Requester

Requester object to make HTTP requests to the Jobmon Flask services.

Functions

http_request_ok(→ bool)	Return True if HTTP return codes that are deemed ok.
get_content(→ Tuple[int, Any])	Parse the response.

Module Contents

core.requester.logger

core.requester.http_request_ok(status_code: int) → bool

Return True if HTTP return codes that are deemed ok.

class core.requester.Requester(url: str, route_prefix: str = '', request_timeout: int = 20, retries_timeout: int = 300, retries_attempts: int = 10, use_otlp: bool = False)

Bases: object

Requester object to make HTTP requests to the Jobmon Flask services.

_otlp_api = None

base_url

route_prefix

request_timeout

retries_timeout

retries_attempts

server_structlog_context: Dict[str, str]

classmethod _init_otlp() → None

classmethod from_defaults() → Requester

Instantiate a requester from default config values.

property url: str

Return the base url for the requester.

add_server_structlog_context(**kwargs: Any) → None

Add the structlogging context if it has been provided.

tracing_span(app_route: str, request_type: str) → Any

_maybe_trace(func: Callable) → Callable

_maybe_retry(func: Callable, tenacious: bool) → Any

_send_request(app_route: str, message: dict, request_type: str) → Tuple[int, Any]

send_request(app_route: str, message: dict, request_type: str, tenacious: bool = True) → Tuple[int, Any]

Send a request to the Jobmon server.

core.requester.get_content(response: Any) → Tuple[int, Any]

Parse the response.