diff --git a/pymongo/asynchronous/bulk.py b/pymongo/asynchronous/bulk.py index 029ac2fa8..1ff647567 100644 --- a/pymongo/asynchronous/bulk.py +++ b/pymongo/asynchronous/bulk.py @@ -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 diff --git a/pymongo/asynchronous/client_bulk.py b/pymongo/asynchronous/client_bulk.py index 76a21cfac..d978599c2 100644 --- a/pymongo/asynchronous/client_bulk.py +++ b/pymongo/asynchronous/client_bulk.py @@ -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. diff --git a/pymongo/synchronous/bulk.py b/pymongo/synchronous/bulk.py index 69fb28e8b..1fe663664 100644 --- a/pymongo/synchronous/bulk.py +++ b/pymongo/synchronous/bulk.py @@ -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