get_bus() should return a default RedisBus() instance if the main bus is not registered

2022-04-02 22:47:23 +02:00 · 2022-04-02 22:47:23 +02:00 · 9c25a131fa
parent 4ee7e4db29
commit 9c25a131fa
1 changed files with 5 additions and 2 deletions
--- a/platypush/context/init.py
+++ b/platypush/context/init.py
@ -133,8 +133,11 @@ def get_plugin(plugin_name, reload=False):

 def get_bus() -> Bus:
    global main_bus
-    assert main_bus, 'The bus is not registered'
-    return main_bus
+    if main_bus:
+        return main_bus
+
+    from platypush.bus.redis import RedisBus
+    return RedisBus()


 def get_or_create_event_loop():