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

adding info step_level_in_pipe in tasks_infos

parent f335e6d9
No related branches found
No related tags found
No related merge requests found
Pipeline #127262 passed
...@@ -8,3 +8,4 @@ dist/* ...@@ -8,3 +8,4 @@ dist/*
*.ipynb_checkpoints* *.ipynb_checkpoints*
notebooks/pipelines_tests/* notebooks/pipelines_tests/*
notebooks/*.log notebooks/*.log
build*
__version__ = "0.0.40" __version__ = "0.0.41"
from . import loggs from . import loggs
from .pipes import * from .pipes import *
......
...@@ -391,6 +391,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery | ...@@ -391,6 +391,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery |
"pipe_name": step.pipe_name, "pipe_name": step.pipe_name,
"pipeline_name": step.pipeline_name, "pipeline_name": step.pipeline_name,
"requires": step.requires, "requires": step.requires,
"step_level_in_pipe": step.get_level(selfish=True),
} }
tasks_dynamic_data[step.complete_name] = task_data tasks_dynamic_data[step.complete_name] = task_data
return tasks_dynamic_data return tasks_dynamic_data
......
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