[2025/04/01 07:37:23.775] FAILURE: pymongo.errors.NetworkTimeout: localhost:27017: timed out (configured timeouts: socketTimeoutMS: 100.0ms, connectTimeoutMS: 20000.0ms) ()
 [2025/04/01 07:37:23.775] self = AsyncConnection(<pymongo.network_layer.AsyncNetworkingInterface object at 0x7f28171935c0>) CLOSED at 139810529191376
 [2025/04/01 07:37:23.775] dbname = 'admin'
 [2025/04/01 07:37:23.775] spec = {'$clusterTime': {'clusterTime': Timestamp(1743517456, 7), 'signature': {'hash': b'\x0cfI\xceA\xc9\xcf2\xc8k15\xf7\xbc..., '$db': 'admin', 'configureFailPoint': 'failCommand', 'lsid': {'id': Binary(b'/2.S\xf8*B9\xadTh`\xf9@\xe9$', 4)}, ...}
 [2025/04/01 07:37:23.775] read_preference = Primary()
 [2025/04/01 07:37:23.775] codec_options = CodecOptions(document_class=dict, tz_aware=False, uuid_representation=UuidRepresentation.UNSPECIFIED, unicode_decode_e...ne, type_registry=TypeRegistry(type_codecs=[], fallback_encoder=None), datetime_conversion=DatetimeConversion.DATETIME)
 [2025/04/01 07:37:23.775] check = True, allowable_errors = None, read_concern = None, write_concern = None
 [2025/04/01 07:37:23.775] parse_write_concern_error = False, collation = None
 [2025/04/01 07:37:23.775] session = <pymongo.asynchronous.client_session.AsyncClientSession object at 0x7f2824a5e0f0>
 [2025/04/01 07:37:23.775] client = AsyncMongoClient(host=['localhost:27017'], document_class=dict, tz_aware=False, connect=True, tls=True, tlscertificate...a.pem', event_listeners=[<test.unified_format_shared.EventListenerUtil object at 0x7f2816a19fd0>], sockettimeoutms=100)
 [2025/04/01 07:37:23.775] retryable_write = False, publish_events = True, user_fields = None
 [2025/04/01 07:37:23.775] exhaust_allowed = False
 [2025/04/01 07:37:23.775]     @_handle_reauth
 [2025/04/01 07:37:23.775]     async def command(
 [2025/04/01 07:37:23.775]         self,
 [2025/04/01 07:37:23.775]         dbname: str,
 [2025/04/01 07:37:23.775]         spec: MutableMapping[str, Any],
 [2025/04/01 07:37:23.775]         read_preference: _ServerMode = ReadPreference.PRIMARY,
 [2025/04/01 07:37:23.775]         codec_options: CodecOptions = DEFAULT_CODEC_OPTIONS,
 [2025/04/01 07:37:23.775]         check: bool = True,
 [2025/04/01 07:37:23.775]         allowable_errors: Optional[Sequence[Union[str, int]]] = None,
 [2025/04/01 07:37:23.775]         read_concern: Optional[ReadConcern] = None,
 [2025/04/01 07:37:23.775]         write_concern: Optional[WriteConcern] = None,
 [2025/04/01 07:37:23.775]         parse_write_concern_error: bool = False,
 [2025/04/01 07:37:23.775]         collation: Optional[_CollationIn] = None,
 [2025/04/01 07:37:23.775]         session: Optional[AsyncClientSession] = None,
 [2025/04/01 07:37:23.775]         client: Optional[AsyncMongoClient] = None,
 [2025/04/01 07:37:23.775]         retryable_write: bool = False,
 [2025/04/01 07:37:23.775]         publish_events: bool = True,
 [2025/04/01 07:37:23.775]         user_fields: Optional[Mapping[str, Any]] = None,
 [2025/04/01 07:37:23.775]         exhaust_allowed: bool = False,
 [2025/04/01 07:37:23.775]     ) -> dict[str, Any]:
 [2025/04/01 07:37:23.775]         """Execute a command or raise an error.
 [2025/04/01 07:37:23.775]     
 [2025/04/01 07:37:23.775]         :param dbname: name of the database on which to run the command
 [2025/04/01 07:37:23.775]         :param spec: a command document as a dict, SON, or mapping object
 [2025/04/01 07:37:23.775]         :param read_preference: a read preference
 [2025/04/01 07:37:23.775]         :param codec_options: a CodecOptions instance
 [2025/04/01 07:37:23.775]         :param check: raise OperationFailure if there are errors
 [2025/04/01 07:37:23.775]         :param allowable_errors: errors to ignore if `check` is True
 [2025/04/01 07:37:23.775]         :param read_concern: The read concern for this command.
 [2025/04/01 07:37:23.775]         :param write_concern: The write concern for this command.
 [2025/04/01 07:37:23.775]         :param parse_write_concern_error: Whether to parse the
 [2025/04/01 07:37:23.775]             ``writeConcernError`` field in the command response.
 [2025/04/01 07:37:23.775]         :param collation: The collation for this command.
 [2025/04/01 07:37:23.775]         :param session: optional AsyncClientSession instance.
 [2025/04/01 07:37:23.775]         :param client: optional AsyncMongoClient for gossipping $clusterTime.
 [2025/04/01 07:37:23.775]         :param retryable_write: True if this command is a retryable write.
 [2025/04/01 07:37:23.775]         :param publish_events: Should we publish events for this command?
 [2025/04/01 07:37:23.775]         :param user_fields: Response fields that should be decoded
 [2025/04/01 07:37:23.775]             using the TypeDecoders from codec_options, passed to
 [2025/04/01 07:37:23.775]             bson._decode_all_selective.
 [2025/04/01 07:37:23.775]         """
 [2025/04/01 07:37:23.775]         self.validate_session(client, session)
 [2025/04/01 07:37:23.775]         session = _validate_session_write_concern(session, write_concern)
 [2025/04/01 07:37:23.775]     
 [2025/04/01 07:37:23.775]         # Ensure command name remains in first place.
 [2025/04/01 07:37:23.775]         if not isinstance(spec, ORDERED_TYPES):  # type:ignore[arg-type]
 [2025/04/01 07:37:23.775]             spec = dict(spec)
 [2025/04/01 07:37:23.775]     
 [2025/04/01 07:37:23.775]         if not (write_concern is None or write_concern.acknowledged or collation is None):
 [2025/04/01 07:37:23.775]             raise ConfigurationError("Collation is unsupported for unacknowledged writes.")
 [2025/04/01 07:37:23.775]     
 [2025/04/01 07:37:23.775]         self.add_server_api(spec)
 [2025/04/01 07:37:23.775]         if session:
 [2025/04/01 07:37:23.775]             session._apply_to(spec, retryable_write, read_preference, self)
 [2025/04/01 07:37:23.775]         self.send_cluster_time(spec, session, client)
 [2025/04/01 07:37:23.775]         listeners = self.listeners if publish_events else None
 [2025/04/01 07:37:23.775]         unacknowledged = bool(write_concern and not write_concern.acknowledged)
 [2025/04/01 07:37:23.775]         if self.op_msg_enabled:
 [2025/04/01 07:37:23.775]             self._raise_if_not_writable(unacknowledged)
 [2025/04/01 07:37:23.775]         try:
 [2025/04/01 07:37:23.775] >           return await command(
 [2025/04/01 07:37:23.775]                 self,
 [2025/04/01 07:37:23.775]                 dbname,
 [2025/04/01 07:37:23.775]                 spec,
 [2025/04/01 07:37:23.775]                 self.is_mongos,
 [2025/04/01 07:37:23.775]                 read_preference,
 [2025/04/01 07:37:23.775]                 codec_options,
 [2025/04/01 07:37:23.775]                 session,
 [2025/04/01 07:37:23.775]                 client,
 [2025/04/01 07:37:23.775]                 check,
 [2025/04/01 07:37:23.775]                 allowable_errors,
 [2025/04/01 07:37:23.775]                 self.address,
 [2025/04/01 07:37:23.775]                 listeners,
 [2025/04/01 07:37:23.775]                 self.max_bson_size,
 [2025/04/01 07:37:23.775]                 read_concern,
 [2025/04/01 07:37:23.775]                 parse_write_concern_error=parse_write_concern_error,
 [2025/04/01 07:37:23.775]                 collation=collation,
 [2025/04/01 07:37:23.775]                 compression_ctx=self.compression_context,
 [2025/04/01 07:37:23.775]                 use_op_msg=self.op_msg_enabled,
 [2025/04/01 07:37:23.775]                 unacknowledged=unacknowledged,
 [2025/04/01 07:37:23.775]                 user_fields=user_fields,
 [2025/04/01 07:37:23.775]                 exhaust_allowed=exhaust_allowed,
 [2025/04/01 07:37:23.775]                 write_concern=write_concern,
 [2025/04/01 07:37:23.775]             )
 [2025/04/01 07:37:23.775] pymongo/asynchronous/pool.py:410: 
 [2025/04/01 07:37:23.775] _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
 [2025/04/01 07:37:23.775] pymongo/asynchronous/network.py:198: in command
 [2025/04/01 07:37:23.775]     reply = await async_receive_message(conn, request_id)
 [2025/04/01 07:37:23.775] _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
 [2025/04/01 07:37:23.775] conn = AsyncConnection(<pymongo.network_layer.AsyncNetworkingInterface object at 0x7f28171935c0>) CLOSED at 139810529191376
 [2025/04/01 07:37:23.775] request_id = 1626425041, max_message_size = 48000000
 [2025/04/01 07:37:23.775]     async def async_receive_message(
 [2025/04/01 07:37:23.775]         conn: AsyncConnection,
 [2025/04/01 07:37:23.775]         request_id: Optional[int],
 [2025/04/01 07:37:23.775]         max_message_size: int = MAX_MESSAGE_SIZE,
 [2025/04/01 07:37:23.775]     ) -> Union[_OpReply, _OpMsg]:
 [2025/04/01 07:37:23.775]         """Receive a raw BSON message or raise socket.error."""
 [2025/04/01 07:37:23.775]         timeout: Optional[Union[float, int]]
 [2025/04/01 07:37:23.775]         timeout = conn.conn.gettimeout
 [2025/04/01 07:37:23.775]         if _csot.get_timeout():
 [2025/04/01 07:37:23.775]             deadline = _csot.get_deadline()
 [2025/04/01 07:37:23.775]         else:
 [2025/04/01 07:37:23.775]             if timeout:
 [2025/04/01 07:37:23.775]                 deadline = time.monotonic() + timeout
 [2025/04/01 07:37:23.775]             else:
 [2025/04/01 07:37:23.775]                 deadline = None
 [2025/04/01 07:37:23.775]         if deadline:
 [2025/04/01 07:37:23.775]             # When the timeout has expired perform one final check to
 [2025/04/01 07:37:23.775]             # see if the socket is readable. This helps avoid spurious
 [2025/04/01 07:37:23.775]             # timeouts on AWS Lambda and other FaaS environments.
 [2025/04/01 07:37:23.775]             timeout = max(deadline - time.monotonic(), 0)
 [2025/04/01 07:37:23.775]     
 [2025/04/01 07:37:23.775]         cancellation_task = create_task(_poll_cancellation(conn))
 [2025/04/01 07:37:23.775]         read_task = create_task(conn.conn.get_conn.read(request_id, max_message_size))
 [2025/04/01 07:37:23.775]         tasks = [read_task, cancellation_task]
 [2025/04/01 07:37:23.775]         try:
 [2025/04/01 07:37:23.775]             done, pending = await asyncio.wait(
 [2025/04/01 07:37:23.775]                 tasks, timeout=timeout, return_when=asyncio.FIRST_COMPLETED
 [2025/04/01 07:37:23.775]             )
 [2025/04/01 07:37:23.775]             for task in pending:
 [2025/04/01 07:37:23.775]                 task.cancel()
 [2025/04/01 07:37:23.775]             if pending:
 [2025/04/01 07:37:23.775]                 await asyncio.wait(pending)
 [2025/04/01 07:37:23.775]             if len(done) == 0:
 [2025/04/01 07:37:23.775] >               raise socket.timeout("timed out")
 [2025/04/01 07:37:23.775] E               TimeoutError: timed out
 [2025/04/01 07:37:23.775] pymongo/network_layer.py:724: TimeoutError
 [2025/04/01 07:37:23.775] The above exception was the direct cause of the following exception:
 [2025/04/01 07:37:23.775] test/asynchronous/__init__.py:909: in _callCleanup
 [2025/04/01 07:37:23.775]     self._callMaybeAsync(function, *args, **kwargs)
 [2025/04/01 07:37:23.775] test/asynchronous/__init__.py:917: in _callMaybeAsync
 [2025/04/01 07:37:23.775]     return get_loop().run_until_complete(func(*args, **kwargs))
 [2025/04/01 07:37:23.775] /opt/python/3.13/lib/python3.13/asyncio/base_events.py:725: in run_until_complete
 [2025/04/01 07:37:23.775]     return future.result()
 [2025/04/01 07:37:23.775] test/asynchronous/__init__.py:934: in configure_fail_point
 [2025/04/01 07:37:23.775]     await client.admin.command(cmd)
 [2025/04/01 07:37:23.775] pymongo/_csot.py:109: in csot_wrapper
 [2025/04/01 07:37:23.775]     return await func(self, *args, **kwargs)
 [2025/04/01 07:37:23.775] pymongo/asynchronous/database.py:932: in command
 [2025/04/01 07:37:23.775]     return await self._command(
 [2025/04/01 07:37:23.775] pymongo/asynchronous/database.py:770: in _command
 [2025/04/01 07:37:23.775]     return await conn.command(
 [2025/04/01 07:37:23.775] pymongo/asynchronous/helpers.py:47: in inner
 [2025/04/01 07:37:23.775]     return await func(*args, **kwargs)
 [2025/04/01 07:37:23.775] pymongo/asynchronous/pool.py:438: in command
 [2025/04/01 07:37:23.775]     await self._raise_connection_failure(error)
 [2025/04/01 07:37:23.775] pymongo/asynchronous/pool.py:642: in _raise_connection_failure
 [2025/04/01 07:37:23.775]     _raise_connection_failure(self.address, error, timeout_details=details)
 [2025/04/01 07:37:23.775] _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
 [2025/04/01 07:37:23.775] address = ('localhost', 27017), error = TimeoutError('timed out')
 [2025/04/01 07:37:23.775] msg_prefix = None
 [2025/04/01 07:37:23.775] timeout_details = {'connectTimeoutMS': 20000.0, 'socketTimeoutMS': 100.0}
 [2025/04/01 07:37:23.775]     def _raise_connection_failure(
 [2025/04/01 07:37:23.775]         address: Any,
 [2025/04/01 07:37:23.775]         error: Exception,
 [2025/04/01 07:37:23.775]         msg_prefix: Optional[str] = None,
 [2025/04/01 07:37:23.775]         timeout_details: Optional[dict[str, float]] = None,
 [2025/04/01 07:37:23.775]     ) -> NoReturn:
 [2025/04/01 07:37:23.775]         """Convert a socket.error to ConnectionFailure and raise it."""
 [2025/04/01 07:37:23.775]         host, port = address
 [2025/04/01 07:37:23.775]         # If connecting to a Unix socket, port will be None.
 [2025/04/01 07:37:23.775]         if port is not None:
 [2025/04/01 07:37:23.775]             msg = "%s:%d: %s" % (host, port, error)
 [2025/04/01 07:37:23.775]         else:
 [2025/04/01 07:37:23.775]             msg = f"{host}: {error}"
 [2025/04/01 07:37:23.775]         if msg_prefix:
 [2025/04/01 07:37:23.775]             msg = msg_prefix + msg
 [2025/04/01 07:37:23.775]         if "configured timeouts" not in msg:
 [2025/04/01 07:37:23.775]             msg += format_timeout_details(timeout_details)
 [2025/04/01 07:37:23.775]         if isinstance(error, socket.timeout):
 [2025/04/01 07:37:23.775] >           raise NetworkTimeout(msg) from error
 [2025/04/01 07:37:23.775] E           pymongo.errors.NetworkTimeout: localhost:27017: timed out (configured timeouts: socketTimeoutMS: 100.0ms, connectTimeoutMS: 20000.0ms)
 [2025/04/01 07:37:23.775] pymongo/pool_shared.py:140: NetworkTimeout