Daniel Mesquita
01/30/2025, 5:25 PMbootstrap_project(PROJECT_ROOT)
class TargetShare(TypedDict):
min: float
max: float
@supress_logs
def run_kvi_engine_with_inputs(
kvi_target: TargetShare, foreground_target: TargetShare
) -> pd.DataFrame:
with KedroSession.create(project_path=PROJECT_ROOT) as session:
context: KedroContext = session.load_context()
catalog: DataCatalog = context.catalog
updated_params = context.params | {
“kvi_engine.product_group_target_boundaries”: {
“kvi”: kvi_target,
“foreground”: foreground_target,
}
}
catalog.add(“parameters”, MemoryDataSet(updated_params), replace=True)
context._extra_params = updated_params
session.run(pipeline_name=“kvi_engine”)
rank_output = catalog.load(“kvi_engine.kvi_rank_output”)
#rank_output is not changing
return rank_output
Hall
01/30/2025, 5:25 PMRavi Kumar Pilla
01/30/2025, 5:35 PMadd_feed_dict
- https://docs.kedro.org/en/0.18.9/kedro.io.DataCatalog.html#kedro.io.DataCatalog.add_feed_dict ?Daniel Mesquita
01/30/2025, 5:41 PMRavi Kumar Pilla
01/30/2025, 5:44 PMRavi Kumar Pilla
01/30/2025, 6:08 PMDaniel Mesquita
01/30/2025, 6:09 PMRavi Kumar Pilla
01/30/2025, 6:10 PMRavi Kumar Pilla
01/30/2025, 6:50 PMDaniel Mesquita
01/30/2025, 7:54 PM