diff --git a/src/delta_barth/pipelines.py b/src/delta_barth/pipelines.py index e69de29..4dafe38 100644 --- a/src/delta_barth/pipelines.py +++ b/src/delta_barth/pipelines.py @@ -0,0 +1,15 @@ +"""collection of configured data pipelines, intended to be invoked from C#""" + +from datetime import datetime as Datetime + +from delta_barth.analysis import forecast +from delta_barth.management import SESSION + + +def pipeline_sales_forecast( + company_id: int | None, + start_date: Datetime | None, +) -> str: + result = forecast.pipeline(SESSION, company_id=company_id, start_date=start_date) + + return result.model_dump_json()