From d5d264c259b78b06db7e69be2c93491f55f3f4ac Mon Sep 17 00:00:00 2001 From: Timothe Jost <timothe.jost@wanadoo.fr> Date: Thu, 20 Mar 2025 19:03:13 +0100 Subject: [PATCH] fix typo --- src/pypelines/__init__.py | 2 +- src/pypelines/celery_tasks.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index e56db64..b9cdce9 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 7f79a0e..5dcda6f 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 -- GitLab