v0.3.1

Author: GitRon

CHANGES.md

@@ -1,5 +1,8 @@
 # Changelog
 
+* *0.3.1* (2025-03-19)
+  * Added a paranoid-ish test to check that the import logic isn't breaking any testing functionality
+
 * *0.3.0* (2025-03-19)
   * The whole queue iteration now is wrapped in a transaction atomic
 

queuebie/__init__.py

@@ -1,6 +1,6 @@
 """Simple message queue for commands and events (CQRS)"""
 
-__version__ = "0.3.0"
+__version__ = "0.3.1"
 
 from queuebie.registry import MessageRegistry
 

testapp/handlers/commands/testapp.py

@@ -43,3 +43,13 @@ def create_user(context: CreateUser):
 @message_registry.register_command(command=RaiseRuntimeError)
 def raise_exception(context: RaiseRuntimeError):
     raise RuntimeError(context.error_msg)
+
+
+class MyClass:
+    """
+    This is a test class since we observed the behaviour that in a similar setup, the "forced"
+    import was breaking mocking.
+    """
+
+    def process(self):
+        return 42

tests/test_registry.py

@@ -9,6 +9,7 @@
 from queuebie import MessageRegistry
 from queuebie.exceptions import RegisterOutOfScopeCommandError
 from queuebie.settings import get_queuebie_cache_key
+from testapp.handlers.commands.testapp import MyClass
 from testapp.messages.commands.my_commands import CriticalCommand, DoSomething
 from testapp.messages.events.my_events import (
     SomethingHappened,
@@ -191,3 +192,16 @@ def test_message_autodiscover_load_handlers_from_cache_dummy_cache(*args):
 
     assert len(commands) == 0
     assert len(events) == 0
+
+
+@mock.patch.object(MyClass, "process")
+def test_registry_forced_import_doesnt_break_mocking(mocked_process):
+    """
+    This is a test for ensuring that the "forced" import isn't breaking mocking features.
+    """
+
+    def my_func():
+        return MyClass().process()
+
+    my_func()
+    mocked_process.assert_called_once()