From f335e6d9095542f96cfe4b2946f50e13da5e50bc Mon Sep 17 00:00:00 2001
From: Timothe Jost <timothe.jost@wanadoo.fr>
Date: Thu, 28 Mar 2024 03:24:18 +0100
Subject: [PATCH] app_name for the defaults tasks
---
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 528d977..6a15a4e 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 6095c0a..9a93e29 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]
--
GitLab