INNER CODE UNIT · Python

post_decommission_ack

ChrispyBacon-dev/DockFlare · dockflare-agent/app/main.py:577

def post_decommission_ack(operation_id, payload):
    global last_successful_master_contact
    endpoint = f"{MASTER_URL}/api/v2/agents/{AGENT_ID}/decommission/{operation_id}/ack"
    body = dict(payload)
    body["operation_id"] = operation_id
    if PROTOCOL_VERSION == 2:
        body["agent_session_id"] = AGENT_SESSION_ID
    try:
        response = requests.post(endpoint, json=body, headers=get_headers(), timeout=60)
        if response.status_code == 200 and _safe_response_code(response) == "acknowledged":
            last_successful_master_contact = datetime.now(timezone.utc)
            return True
        logging.error(
            "Master rejected decommission acknowledgement (status=%s, code=%s)",
            response.status_code,
            _safe_response_code(response),
        )
    except requests.exceptions.RequestException as exc:

View source record →