From a0b81f6b51012d52e609921f2aa40f19dbe4be78 Mon Sep 17 00:00:00 2001
From: Timothe Jost <timothe.jost@wanadoo.fr>
Date: Thu, 28 Mar 2024 17:38:47 +0100
Subject: [PATCH] adding info step_level_in_pipe in tasks_infos
---
.gitignore | 1 +
src/pypelines/__init__.py | 2 +-
src/pypelines/celery_tasks.py | 1 +
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/.gitignore b/.gitignore
index e316670..8ff2ba5 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 6a15a4e..e0de8e0 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 9a93e29..99a5bf9 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
--
GitLab