From ecb92fca3e9a256206ed6519aa4ece9a716b9224 Mon Sep 17 00:00:00 2001 From: edraft Date: Thu, 25 Sep 2025 08:46:02 +0200 Subject: [PATCH] Minor fixes --- src/cpl-application/cpl/application/host.py | 9 +++------ src/cpl-dependency/cpl/dependency/service_provider.py | 2 +- 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/src/cpl-application/cpl/application/host.py b/src/cpl-application/cpl/application/host.py index 5571d125..551d1557 100644 --- a/src/cpl-application/cpl/application/host.py +++ b/src/cpl-application/cpl/application/host.py @@ -51,8 +51,6 @@ class Host: @classmethod def run_app(cls, func: Callable, *args, **kwargs): - loop = cls.get_loop() - cls.run_start_tasks() cls.run_hosted_services() @@ -61,8 +59,7 @@ class Host: if asyncio.iscoroutinefunction(func): app_task = asyncio.create_task(func(*args, **kwargs)) else: - loop = asyncio.get_running_loop() - app_task = loop.run_in_executor(None, func, *args, **kwargs) + app_task = cls.get_loop().run_in_executor(None, func, *args, **kwargs) await asyncio.wait( [app_task, *cls._tasks.values()], @@ -73,11 +70,11 @@ class Host: finally: await cls._stop_all() - loop.run_until_complete(runner()) + cls.get_loop().run_until_complete(runner()) @classmethod def run(cls, func: Callable, *args, **kwargs): if asyncio.iscoroutinefunction(func): - return cls._loop.run_until_complete(func(*args, **kwargs)) + return cls.get_loop().run_until_complete(func(*args, **kwargs)) return func(*args, **kwargs) \ No newline at end of file diff --git a/src/cpl-dependency/cpl/dependency/service_provider.py b/src/cpl-dependency/cpl/dependency/service_provider.py index 1ba688d2..f6ed2318 100644 --- a/src/cpl-dependency/cpl/dependency/service_provider.py +++ b/src/cpl-dependency/cpl/dependency/service_provider.py @@ -161,7 +161,7 @@ class ServiceProvider: implementations = [] if typing.get_origin(service_type) == list: raise Exception(f"Invalid type {service_type}! Expected single type not list of type") - implementations.extend(self._get_services(service_type, None, *args, **kwargs)) + implementations.extend(self._get_services(service_type, *args, **kwargs)) return implementations def get_service_types(self, service_type: Type[T]) -> list[Type[T]]: