v4.0.11

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "aiomql"
-version = "4.0.10"
+version = "4.0.11"
 readme = "README.md"
 requires-python = ">=3.11"
 classifiers = [

src/aiomql/lib/executor.py

@@ -71,8 +71,11 @@ class Executor:
 
     async def run_coroutine_tasks(self):
         """Run all coroutines in the executor"""
-        await asyncio.gather(*[coroutine(**kwargs) for coroutine, kwargs in self.coroutines.items()],
+        try:
-                             return_exceptions=True)
+            await asyncio.gather(*[coroutine(**kwargs) for coroutine, kwargs in self.coroutines.items()],
+                                 return_exceptions=True)
+        except Exception as err:
+            logger.error("%s: Error occurred in run_coroutine_tasks", err)
 
     @staticmethod
     def run_coroutine_task(coroutine, kwargs):
@@ -98,18 +101,14 @@ class Executor:
                 if self.timeout is not None and self.timeout < (asyncio.get_event_loop().time() - start):
                     self.config.shutdown = True
                     break
-
+                timeout = self.timeout or 1
-                timeout = 1 if self.timeout else 30
                 await asyncio.sleep(timeout)
-
             for strategy in self.strategy_runners:
                 strategy.running = False
-
             self.config.task_queue.cancel()
 
             if self.config.backtest_engine is not None:
                 self.config.backtest_engine.stop_testing = True
-
             self.executor.shutdown(wait=False, cancel_futures=False)
 
             if self.config.force_shutdown: