diff --git a/asab/storage/upsertor.py b/asab/storage/upsertor.py index e1e0ae3e5..301056997 100644 --- a/asab/storage/upsertor.py +++ b/asab/storage/upsertor.py @@ -167,15 +167,17 @@ def _webhook(self, data, uri, auth=None): response = conn.getresponse() if response.status // 100 != 2: text = response.read() - L.error("Webhook endpoint responded with {}:\n{}".format(response.status, text)) + L.error( + "Webhook endpoint responded with {}:\n{}".format(response.status, text), + struct_data={"uri": uri}) return self.WebhookResponseData = json.load(response) except ConnectionRefusedError: L.error("Webhook call failed: Connection refused.", struct_data={"uri": uri}) return except json.decoder.JSONDecodeError as e: - L.error("Failed to decode JSON response from webhook: {}".format(str(e))) + L.error("Failed to decode JSON response from webhook: {}".format(str(e)), struct_data={"uri": uri}) except Exception as e: - L.error("Webhook call failed with {}: {}".format(type(e).__name__, str(e))) + L.error("Webhook call failed with {}: {}".format(type(e).__name__, str(e)), struct_data={"uri": uri}) finally: conn.close()