From abdfb274e44dd9f7eafb27279fd1d4d31a10114c Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 4 Mar 2026 12:54:44 -0800 Subject: [PATCH] Typing --- pymongo/asynchronous/bulk.py | 4 ++-- pymongo/asynchronous/client_bulk.py | 4 ++-- pymongo/synchronous/bulk.py | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) 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