diff --git a/.gitignore b/.gitignore index e3166703bb760c9d3692ec15cf9666c4afbd0e20..8ff2ba514032f47cc179917fb56fee95a7196025 100644 --- a/.gitignore +++ b/.gitignore @@ -8,3 +8,4 @@ dist/* *.ipynb_checkpoints* notebooks/pipelines_tests/* notebooks/*.log +build* diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index 6a15a4ee02c737e383acdd6d4dc1d10d070456be..e0de8e051cc9d3c2a53d26c2e5b0a6c51cb2f940 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.40" +__version__ = "0.0.41" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 9a93e29b91299fede0a6a6ab90701308ebf0f3f5..99a5bf937dfa5f054afbaf4ce6ebb5c20c328db5 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -391,6 +391,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | "pipe_name": step.pipe_name, "pipeline_name": step.pipeline_name, "requires": step.requires, + "step_level_in_pipe": step.get_level(selfish=True), } tasks_dynamic_data[step.complete_name] = task_data return tasks_dynamic_data