diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index 74040b269ae91bb8f57b838deedcfa0ebfe86d58..19bd5f6d07fcc3df0756589c1b4b1166428911e1 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.51" +__version__ = "0.0.52" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 039cae9b9c0ad6fc42175efda44e9adfbe00d6a3..b974038dd486e4d58b9cf6fa3d547e973b3b42e3 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -508,7 +508,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | def is_hand_shaken(self): try: - result = self.tasks[f"{app_name}.handshake"].delay(app_name).get(timeout=1) + result = self.tasks[f"{app_name}.handshake"].delay().get(timeout=1) logger.warning(f"Handshake result : {result}") return True except ValueError: