Update log to DEBUG

Disable sync and observer threads in test Connector instance
NeonGeckoCom · Jan 21, 2025 · fe04091 · fe04091
1 parent 079094b
commit fe04091
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -322,7 +322,7 @@ def _on_channel_open(new_channel):
             new_channel.close()
 
         if isinstance(connection, pika.BlockingConnection):
-            LOG.info(f"Using blocking connection for request: {request_data}")
+            LOG.debug(f"Using blocking connection for request: {request_data}")
             _on_channel_open(connection.channel())
         else:
             LOG.debug(f"Using select connection for queue: {queue}")

diff --git a/tests/test_connector.py b/tests/test_connector.py
@@ -365,7 +365,7 @@ def test_emit_mq_message(self):
         callback = Mock(side_effect=lambda *args: callback_event.set())
         connector.register_consumer("test_consumer", vhost=test_vhost,
                                     queue=test_queue, callback=callback)
-        connector.run()
+        connector.run(run_sync=False, run_observer=False)
 
         close_event = threading.Event()
         on_open = Mock()