PYTHON-5821 - Fix ordering issue between event publish and logging fo… (#2867)

Author: NoahStapp

pymongo/asynchronous/pool.py

@@ -511,9 +511,7 @@ async def authenticate(self, reauthenticate: bool = False) -> None:
                 await auth.authenticate(creds, self, reauthenticate=reauthenticate)
             self.ready = True
             duration = time.monotonic() - self.creation_time
-            if self.enabled_for_cmap:
-                assert self.listeners is not None
-                self.listeners.publish_connection_ready(self.address, self.id, duration)
+            # Log before publishing event to prevent potential listener preemption in tests
             if self.enabled_for_logging and _CONNECTION_LOGGER.isEnabledFor(logging.DEBUG):
                 _debug_log(
                     _CONNECTION_LOGGER,
@@ -524,6 +522,9 @@ async def authenticate(self, reauthenticate: bool = False) -> None:
                     driverConnectionId=self.id,
                     durationMS=duration,
                 )
+            if self.enabled_for_cmap:
+                assert self.listeners is not None
+                self.listeners.publish_connection_ready(self.address, self.id, duration)
 
     def validate_session(
         self, client: Optional[AsyncMongoClient[Any]], session: Optional[AsyncClientSession]
@@ -1028,9 +1029,7 @@ async def connect(self, handler: Optional[_MongoClientErrorHandler] = None) -> A
             self.active_contexts.add(tmp_context)
 
         listeners = self.opts._event_listeners
-        if self.enabled_for_cmap:
-            assert listeners is not None
-            listeners.publish_connection_created(self.address, conn_id)
+        # Log before publishing event to prevent potential listener preemption in tests
         if self.enabled_for_logging and _CONNECTION_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
                 _CONNECTION_LOGGER,
@@ -1040,6 +1039,9 @@ async def connect(self, handler: Optional[_MongoClientErrorHandler] = None) -> A
                 serverPort=self.address[1],
                 driverConnectionId=conn_id,
             )
+        if self.enabled_for_cmap:
+            assert listeners is not None
+            listeners.publish_connection_created(self.address, conn_id)
 
         try:
             networking_interface = await _configured_protocol_interface(self.address, self.opts)

pymongo/synchronous/pool.py

@@ -511,9 +511,7 @@ def authenticate(self, reauthenticate: bool = False) -> None:
                 auth.authenticate(creds, self, reauthenticate=reauthenticate)
             self.ready = True
             duration = time.monotonic() - self.creation_time
-            if self.enabled_for_cmap:
-                assert self.listeners is not None
-                self.listeners.publish_connection_ready(self.address, self.id, duration)
+            # Log before publishing event to prevent potential listener preemption in tests
             if self.enabled_for_logging and _CONNECTION_LOGGER.isEnabledFor(logging.DEBUG):
                 _debug_log(
                     _CONNECTION_LOGGER,
@@ -524,6 +522,9 @@ def authenticate(self, reauthenticate: bool = False) -> None:
                     driverConnectionId=self.id,
                     durationMS=duration,
                 )
+            if self.enabled_for_cmap:
+                assert self.listeners is not None
+                self.listeners.publish_connection_ready(self.address, self.id, duration)
 
     def validate_session(
         self, client: Optional[MongoClient[Any]], session: Optional[ClientSession]
@@ -1024,9 +1025,7 @@ def connect(self, handler: Optional[_MongoClientErrorHandler] = None) -> Connect
             self.active_contexts.add(tmp_context)
 
         listeners = self.opts._event_listeners
-        if self.enabled_for_cmap:
-            assert listeners is not None
-            listeners.publish_connection_created(self.address, conn_id)
+        # Log before publishing event to prevent potential listener preemption in tests
         if self.enabled_for_logging and _CONNECTION_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
                 _CONNECTION_LOGGER,
@@ -1036,6 +1035,9 @@ def connect(self, handler: Optional[_MongoClientErrorHandler] = None) -> Connect
                 serverPort=self.address[1],
                 driverConnectionId=conn_id,
             )
+        if self.enabled_for_cmap:
+            assert listeners is not None
+            listeners.publish_connection_created(self.address, conn_id)
 
         try:
             networking_interface = _configured_socket_interface(self.address, self.opts)