testing

Author: NoahStapp

pymongo/asynchronous/mongo_client.py

@@ -34,6 +34,7 @@
 
 import contextlib
 import os
+import threading
 import traceback
 import warnings
 import weakref
@@ -2567,7 +2568,7 @@ async def run(self) -> T:
             self._check_last_error(check_csot=True)
             try:
                 if self._operation in (_Op.LIST_COLLECTIONS, _Op.INSERT):
-                    print(f"Retryable read for {self._operation}")
+                    print(f"{threading.current_thread().name} -- Retryable read for {self._operation}")
                 res = await self._read() if self._is_read else await self._write()
                 if self._operation in (_Op.LIST_COLLECTIONS, _Op.INSERT):
                     print(f"Result for {self._operation}: {res}")

pymongo/asynchronous/network.py

@@ -17,6 +17,7 @@
 
 import datetime
 import logging
+import threading
 import time
 from typing import (
     TYPE_CHECKING,
@@ -135,7 +136,7 @@ async def command(
 
     publish = listeners is not None and listeners.enabled_for_commands
     if name == "listCollections":
-        print(f"Publishing is {publish} listeners: {listeners} {listeners.enabled_for_commands if listeners is not None else 'NONE'}!")
+        print(f"{threading.current_thread().name} -- Publishing is {publish} listeners: {listeners} {listeners.enabled_for_commands if listeners is not None else 'NONE'}!")
     start = datetime.datetime.now()
     if publish:
         speculative_hello = _is_speculative_authenticate(name, spec)