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