diff --git a/pymongo/synchronous/bulk.py b/pymongo/synchronous/bulk.py index 5fef80ec8..69fb28e8b 100644 --- a/pymongo/synchronous/bulk.py +++ b/pymongo/synchronous/bulk.py @@ -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) diff --git a/pymongo/synchronous/client_bulk.py b/pymongo/synchronous/client_bulk.py index f97bae021..090a1c1d7 100644 --- a/pymongo/synchronous/client_bulk.py +++ b/pymongo/synchronous/client_bulk.py @@ -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.