diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index 8adb3b921eddbd734839ce675008bc0d40be3217..ca8dfbc54b8730fda5b84ddf52044ecd934f0da0 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.54" +__version__ = "0.0.55" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 3f7b41e038cdc385f2ff01b9aa3671e365308905..ae6128f4dad281fb54a149f977ea23c50d54a749 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -241,9 +241,7 @@ class CeleryTaskRecord(dict): app: "Celery", task_model: type, task_name: str, pipeline_name: str, session: object, extra=None, **kwargs ): - new_task = task_model( - name=task_name, session=session, arguments=kwargs, status="Waiting", executable=pipeline_name - ) + new_task = task_model(name=task_name, session=session, arguments=kwargs, status=25, executable=pipeline_name) new_task.save() task_dict = new_task.__dict__.copy()