chore: cleanup debug statements

ApeWorX · Jul 13, 2024 · 59f9250 · 59f9250
1 parent 0fb254a
commit 59f9250
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/silverback/subscriptions.py b/silverback/subscriptions.py
@@ -144,23 +144,16 @@ async def get_subscription_data_nowait(
         """
         while True:
             if not (queue := self._subscriptions.get(sub_id)) or queue.empty():
-                logger.debug(
-                    f"Acquiring lock for recv (no wait). (is locked? {self._ws_lock.locked()})"
-                )
                 async with self._ws_lock:
-                    logger.debug("Acquired lock for recv (no wait).")
                     try:
                         await self._receive(timeout=timeout)
                     except TimeoutError:
                         logger.debug("Receive call timed out.")
                         return
-                    else:
-                        logger.debug("Receive call completed.")
             else:
                 try:
                     yield queue.get_nowait()
                 except asyncio.QueueEmpty:
-                    logger.debug("Subscription queue empty.")
                     return
 
     async def unsubscribe(self, sub_id: str) -> bool: