diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index e56db64febfd638575f764e8a69303b2c6143b45..b9cdce9bed0c09034a5c2d4991f78c58b6ee0f12 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.79" +__version__ = "0.0.80" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 7f79a0ef23eccb4d4b26911770f9a1bc82deafa5..5dcda6f3cacba36d7b5b7c1f3b14c5a09ba0788d 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -834,7 +834,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | logger.error(f"No handshake result. All workers are busy ? {e}") return False - def single_worker_start(self: Celery): + def single_worker_start(self: "Celery"): thread = CeleryWorkerThread(self) thread.start() @@ -909,7 +909,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | class CeleryWorkerThread(Thread): - def __init__(self, app: Celery): + def __init__(self, app: "Celery"): super().__init__() self.app = app