diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index 528d977b9c45b2dad4fd531eb13bee8758a728a3..6a15a4ee02c737e383acdd6d4dc1d10d070456be 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.39" +__version__ = "0.0.40" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 6095c0af06c67029763d5c9ee44a8a0e7a775d92..9a93e29b91299fede0a6a6ab90701308ebf0f3f5 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -360,7 +360,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | from celery import Task class handshake(Task): - name = "handshake" + name = f"{app_name}.handshake" def run(self): return f"{node()} is happy to shake your hand and says hello !" @@ -372,7 +372,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | return str(signature.replace(parameters=params))[1:-1].replace(" *,", "") class tasks_infos(Task): - name = "tasks_infos" + name = f"{app_name}.tasks_infos" def run(self, app_name): app = APPLICATIONS_STORE[app_name]