Join the Kedro community

Home
Members
Daniel Mesquita
D
Daniel Mesquita
Offline, last seen 2 weeks ago
Joined January 30, 2025

Hey team, I am working with a codease that uses kedro 0.18.3 and cannot change it. I need to run a pipeline through a python code iterating over some parameters. However, running the way I researched does not updtate the params. Is there something in my code I might be missing:
```bootstrap_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
```

8 comments
R
D