Skip to content
This repository was archived by the owner on Mar 20, 2023. It is now read-only.

Commit 86b9879

Browse files
committed
fix log_request_fail
1 parent 4079eb7 commit 86b9879

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

elasticsearch_async/connection.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,15 +58,15 @@ def perform_request(self, method, url, params=None, body=None, timeout=None, ign
5858
duration = self.loop.time() - start
5959

6060
except asyncio.TimeoutError as e:
61-
self.log_request_fail(method, url, body, self.loop.time() - start, exception=e)
61+
self.log_request_fail(method, url, url_path, body, self.loop.time() - start, exception=e)
6262
raise ConnectionTimeout('TIMEOUT', str(e), e)
6363

6464
except FingerprintMismatch as e:
65-
self.log_request_fail(method, url, body, self.loop.time() - start, exception=e)
65+
self.log_request_fail(method, url, url_path, body, self.loop.time() - start, exception=e)
6666
raise SSLError('N/A', str(e), e)
6767

6868
except ClientError as e:
69-
self.log_request_fail(method, url, body, self.loop.time() - start, exception=e)
69+
self.log_request_fail(method, url, url_path, body, self.loop.time() - start, exception=e)
7070
raise ConnectionError('N/A', str(e), e)
7171

7272
finally:
@@ -75,7 +75,7 @@ def perform_request(self, method, url, params=None, body=None, timeout=None, ign
7575

7676
# raise errors based on http status codes, let the client handle those if needed
7777
if not (200 <= response.status < 300) and response.status not in ignore:
78-
self.log_request_fail(method, url, body, duration, response.status, raw_data)
78+
self.log_request_fail(method, url, url_path, body, duration, status_code=response.status, response=raw_data)
7979
self._raise_error(response.status, raw_data)
8080

8181
self.log_request_success(method, url, url_path, body, response.status, raw_data, duration)

0 commit comments

Comments
 (0)