Skip to content
Snippets Groups Projects
Commit f335e6d9 authored by Timothe Jost's avatar Timothe Jost
Browse files

app_name for the defaults tasks

parent b48b8ea0
No related branches found
No related tags found
No related merge requests found
Pipeline #127196 passed
__version__ = "0.0.39"
__version__ = "0.0.40"
from . import loggs
from .pipes import *
......
......@@ -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]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment