Core: start MockEventNode too (or events wont work)

carrier-io · Mar 27, 2024 · f33088e · f33088e
1 parent e059270
commit f33088e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/pylon/core/tools/event.py b/pylon/core/tools/event.py
@@ -69,6 +69,7 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local events only")
                 self.node = arbiter.MockEventNode()
+                self.node.start()
         elif events_redis:
             try:
                 self.node = arbiter.RedisEventNode(
@@ -86,6 +87,7 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local events only")
                 self.node = arbiter.MockEventNode()
+                self.node.start()
         elif events_socketio:
             try:
                 self.node = arbiter.SocketIOEventNode(
@@ -102,8 +104,10 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local events only")
                 self.node = arbiter.MockEventNode()
+                self.node.start()
         else:
             self.node = arbiter.MockEventNode()
+            self.node.start()
         #
         self.partials = dict()
 

diff --git a/pylon/core/tools/rpc.py b/pylon/core/tools/rpc.py
@@ -71,6 +71,7 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local RPC only")
                 event_node = arbiter.MockEventNode()
+                event_node.start()
         elif rpc_redis:
             try:
                 event_node = arbiter.RedisEventNode(
@@ -88,6 +89,7 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local RPC only")
                 event_node = arbiter.MockEventNode()
+                event_node.start()
         elif rpc_socketio:
             try:
                 event_node = arbiter.SocketIOEventNode(
@@ -104,8 +106,10 @@ def __init__(self, context):
             except:  # pylint: disable=W0702
                 log.exception("Cannot make EventNode instance, using local RPC only")
                 event_node = arbiter.MockEventNode()
+                event_node.start()
         else:
             event_node = arbiter.MockEventNode()
+            event_node.start()
         #
         self.node = arbiter.RpcNode(
             event_node,