From 29698c1a130312b01169e162eb9d94c0b1ecf525 Mon Sep 17 00:00:00 2001
From: Timothe Jost <timothe.jost@wanadoo.fr>
Date: Thu, 4 Apr 2024 23:28:33 +0200
Subject: [PATCH] quick fix
---
src/pypelines/__init__.py | 2 +-
src/pypelines/celery_tasks.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py
index 74040b2..19bd5f6 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 039cae9..b974038 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:
--
GitLab