mongodb/mongo-python-driver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Typing

Browse Source
This commit is contained in:
Noah Stapp 2026-03-04 12:50:31 -08:00
parent cf8f23440a
commit ba530d3c51
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pymongo/synchronous/bulk.py
View File

@ -266,7 +266,7 @@ class _Bulk:
) as telemetry:
try:
reply = bwc.conn.write_command(request_id, msg, bwc.codec) # type: ignore[misc]
telemetry.publish_succeeded(reply)
telemetry.publish_succeeded(reply) # type: ignore[misc, arg-type]
client._process_response(reply, bwc.session) # type: ignore[arg-type]
except Exception as exc:
telemetry.publish_failed(exc)

4
pymongo/synchronous/client_bulk.py
View File

@ -252,7 +252,7 @@ class _ClientBulk:
) as telemetry:
try:
reply = bwc.conn.write_command(request_id, msg, bwc.codec) # type: ignore[misc, arg-type]
telemetry.publish_succeeded(reply)
telemetry.publish_succeeded(reply) # type: ignore[misc, arg-type]
# Process the response from the server.
self.client._process_response(reply, bwc.session) # type: ignore[arg-type]
except Exception as exc:
@ -301,7 +301,7 @@ class _ClientBulk:
else:
# Comply with APM spec.
reply = {"ok": 1}
telemetry.publish_succeeded(reply)
telemetry.publish_succeeded(reply) # type: ignore[misc, arg-type]
except Exception as exc:
telemetry.publish_failed(exc)
# Top-level error will be embedded in ClientBulkWriteException.