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

test

parent ef8b1536
No related branches found
No related tags found
No related merge requests found
Pipeline #127178 passed
__version__ = "0.0.35" __version__ = "0.0.36"
from . import loggs from . import loggs
from .pipes import * from .pipes import *
......
...@@ -280,7 +280,7 @@ class LogTask: ...@@ -280,7 +280,7 @@ class LogTask:
self.logger.removeHandler(self.logger.handlers[-1]) self.logger.removeHandler(self.logger.handlers[-1])
def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery": def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | None":
failure_message = ( failure_message = (
f"Celery app : {app_name} failed to be created." f"Celery app : {app_name} failed to be created."
...@@ -350,10 +350,14 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery": ...@@ -350,10 +350,14 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery":
APPLICATIONS_STORE[app_name] = app APPLICATIONS_STORE[app_name] = app
app.register_task(handshake) from celery import Task
return app class handshake(Task):
name = "handshake"
def run(self):
return f"{node()} is happy to shake your hand and says hello !"
def handshake(): app.register_task(handshake)
return f"{node()} is happy to shake your hand and says hello !"
return app
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