From 8b31548526dd5124cf186a474699e89df1515406 Mon Sep 17 00:00:00 2001 From: foefl Date: Thu, 11 Jun 2026 09:09:05 +0200 Subject: [PATCH] final push before project break --- src/umbreit/pipeline.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/umbreit/pipeline.py b/src/umbreit/pipeline.py index 72c7389..f70dfa0 100644 --- a/src/umbreit/pipeline.py +++ b/src/umbreit/pipeline.py @@ -165,7 +165,9 @@ def clear_result_data() -> None: conn.execute(sql.delete(db.EXT_DOPT_ERGEBNIS)) -def save_result_data_native(results: pl.DataFrame) -> None: +def save_result_data_native( + results: pl.DataFrame, +) -> None: results = results.with_columns( [ pl.when(pl.col(c)).then(pl.lit("Y")).otherwise(pl.lit("N")).alias(c) @@ -366,6 +368,7 @@ def get_expr_order_qty( return func +# // begin workflows def wf900( pipe_result: PipelineResult, ) -> PipelineResult: