Skip to content

connector

dandy.http.connector

HttpConnector

Bases: BaseConnector

Source code in dandy/http/connector.py 
19
20
def __init__(self, config: HttpConnectorConfig):
    self._config = config

post_request

Source code in dandy/http/connector.py 
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
def post_request(self, json_body_dict: dict) -> dict:
    response: Response = Response(status_code=0)

    for _ in range(settings.HTTP_CONNECTION_RETRY_COUNT + 1):

        response = httpx.request(
            'POST',
            self._config.url.to_str(),
            headers=self._config.headers,
            content=json.dumps(json_body_dict).encode('utf-8'),
            timeout=settings.DEFAULT_LLM_REQUEST_TIMEOUT
        )

        if response.status_code == 200 or response.status_code == 201:
            json_data = json.loads(response.text)
            return json_data

        sleep(0.1)

    else:
        if response.status_code != 0:
            raise HttpConnectorCriticalException(
                f'HTTP service request failed with status code {response.status_code} and the following message "{response.text}" after {settings.HTTP_CONNECTION_RETRY_COUNT} attempts')
        else:
            raise HttpConnectorCriticalException(
                f'HTTP service request failed after {settings.HTTP_CONNECTION_RETRY_COUNT} attempts for unknown reasons')