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:54:44 -08:00
parent ba530d3c51
commit abdfb274e4
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pymongo/asynchronous/bulk.py
View File

@ -266,7 +266,7 @@ class _AsyncBulk:
) as telemetry:
try:
reply = await 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]
await client._process_response(reply, bwc.session) # type: ignore[arg-type]
except Exception as exc:
telemetry.publish_failed(exc)
@ -310,7 +310,7 @@ class _AsyncBulk:
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)
raise

4
pymongo/asynchronous/client_bulk.py
View File

@ -252,7 +252,7 @@ class _AsyncClientBulk:
) as telemetry:
try:
reply = await 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.
await self.client._process_response(reply, bwc.session) # type: ignore[arg-type]
except Exception as exc:
@ -301,7 +301,7 @@ class _AsyncClientBulk:
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.

2
pymongo/synchronous/bulk.py
View File

@ -310,7 +310,7 @@ class _Bulk:
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)
raise