Merge branch 'main' into support/3.2

zatosource · Nov 8, 2024 · 67d5b4c · 67d5b4c
2 parents bf65062 + cac2e4f
commit 67d5b4c
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 4 deletions.
diff --git a/code/zato-common/src/zato/common/aux_server/base.py b/code/zato-common/src/zato/common/aux_server/base.py
@@ -99,7 +99,7 @@ def get_odb(config:'AuxServerConfig') -> 'ODBManager':
 
         odb.pool = sql_pool_store[ZATO_ODB_POOL_NAME].pool
         odb.init_session(ZATO_ODB_POOL_NAME, config.main.odb, odb.pool, False)
-        odb.pool.ping(odb.fs_sql_config)
+        _ = odb.pool.ping(odb.fs_sql_config)
 
         return odb
 
@@ -314,7 +314,7 @@ def after_config_hook(
 # ################################################################################################################################
 
     @classmethod
-    def start(
+    def start_from_repo_location(
         class_,                # type: type_[AuxServer]
         *,
         base_dir=None,         # type: strnone
@@ -373,6 +373,18 @@ def start(
         class_.after_config_hook(config, repo_location)
 
         # Run the server now
+        class_._start(config)
+
+# ################################################################################################################################
+
+    @classmethod
+    def start_from_config(class_:'type_[AuxServer]', config:'AuxServerConfig') -> 'None':
+        class_._start(config)
+
+# ################################################################################################################################
+
+    @classmethod
+    def _start(class_:'type_[AuxServer]', config:'AuxServerConfig') -> 'None':
         try:
             class_(config).serve_forever()
         except Exception:

diff --git a/code/zato-common/src/zato/common/ipc/server.py b/code/zato-common/src/zato/common/ipc/server.py
@@ -75,7 +75,7 @@ def my_callback(msg:'Bunch') -> 'str':
     password = 'test.password'
     server_type_suffix = ':test'
 
-    IPCServer.start(
+    IPCServer.start_from_repo_location(
         base_dir=base_dir,
         bind_host=bind_host,
         bind_port=bind_port,

diff --git a/code/zato-scheduler/src/zato/scheduler/main.py b/code/zato-scheduler/src/zato/scheduler/main.py
@@ -27,7 +27,7 @@
 # ################################################################################################################################
 
 def main():
-    SchedulerServer.start()
+    SchedulerServer.start_from_repo_location()
 
 # ################################################################################################################################
 # ################################################################################################################################