Fix issue on python>=3.14

Author: sharpener6

src/scaler/cluster/scheduler.py

@@ -68,7 +68,7 @@ def run(self) -> None:
         setup_logger(self._logging_paths, self._logging_config_file, self._logging_level)
         register_event_loop(self._scheduler_config.event_loop)
 
-        self._loop = asyncio.get_event_loop()
+        self._loop = asyncio.get_running_loop()
         SchedulerProcess.__register_signal(self._loop)
 
         self._task = self._loop.create_task(scheduler_main(self._scheduler_config))

src/scaler/io/ymq/ymq.py

@@ -90,7 +90,7 @@ async def call_async(
     *args: P.args,  # type: ignore
     **kwargs: P.kwargs,  # type: ignore
 ) -> T:
-    loop = asyncio.get_event_loop()
+    loop = asyncio.get_running_loop()
     future = loop.create_future()
 
     def callback(result: Union[T, BaseException]):

src/scaler/version.txt

@@ -1 +1 @@
-1.12.44
+1.12.45

src/scaler/worker/worker.py

@@ -172,7 +172,7 @@ def __initialize(self):
             connector_storage=self._connector_storage,
         )
 
-        self._loop = asyncio.get_event_loop()
+        self._loop = asyncio.get_running_loop()
         self.__register_signal()
         self._task = self._loop.create_task(self.__get_loops())
 

src/scaler/worker_adapter/symphony/worker.py

@@ -129,7 +129,7 @@ def __initialize(self):
             heartbeat_manager=self._heartbeat_manager,
         )
 
-        self._loop = asyncio.get_event_loop()
+        self._loop = asyncio.get_running_loop()
         self.__register_signal()
         self._task = self._loop.create_task(self.__get_loops())