Skip to content

Commit 3bdd381

Browse files
committed
Fix deadline
1 parent b472d3a commit 3bdd381

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pymongo/asynchronous/encryption.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ async def _async_kms_request(
154154
while kms_context.bytes_needed > 0:
155155
# CSOT: update timeout.
156156
conn.settimeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
157-
data = await _async_receive_data_socket(conn, kms_context.bytes_needed)
157+
data = await _async_receive_data_socket(conn, kms_context.bytes_needed, None)
158158
if not data:
159159
raise OSError("KMS connection closed")
160160
kms_context.feed(data)

pymongo/synchronous/encryption.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ def _async_kms_request(
154154
while kms_context.bytes_needed > 0:
155155
# CSOT: update timeout.
156156
conn.settimeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
157-
data = _receive_data_socket(conn, kms_context.bytes_needed)
157+
data = _receive_data_socket(conn, kms_context.bytes_needed, None)
158158
if not data:
159159
raise OSError("KMS connection closed")
160160
kms_context.feed(data)

0 commit comments

Comments
 (0)