diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index edf9cfb16f3e07ba05c0b7543b47eae3b1beedef..d163b5f28963546947efd6363224c8550a6e61da 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.24" +__version__ = "0.0.25" from . import loggs from .pipes import * diff --git a/src/pypelines/pipelines.py b/src/pypelines/pipelines.py index 842e88598f011e782e4a1eb798dc5d9d5a6c916e..25f879d145249273fc84dff2e0c62de0e501955e 100644 --- a/src/pypelines/pipelines.py +++ b/src/pypelines/pipelines.py @@ -144,7 +144,7 @@ class Pipeline: celery = CeleryHandler(self.conf_path, self.pipeline_name) if celery.success: - self.self.celery = celery + self.celery = celery self.use_celery = True else: getLogger().warning( @@ -155,4 +155,4 @@ class Pipeline: def finalize(self): if self.use_celery: - self.celery.app.start() + self.celery.app.start() # pyright: ignore