Luke Dziurzynski
08/30/2023, 3:38 PMdatajoely
08/30/2023, 3:49 PMLuke Dziurzynski
08/30/2023, 3:54 PMNok Lam Chan
08/30/2023, 4:15 PMKedroSession
, essentially you want to run the pipeline like a python function and just take the parameters.
i.e. my_pipeline(params=user_params)
You may have to write a thin wrapper around this to control what can be passed.William Caicedo
08/30/2023, 4:17 PMmetadata = bootstrap_project(Path.cwd())
data_date = get_some_date()
with KedroSession.create(metadata.package_name,
extra_params= {'param_1': param_1,
'param_2': param_2,
'data_date': data_date
}) as session:
pipeline_name = 'one' if some_condition else 'two'
session.run(pipeline_name=pipeline_name)
Nok Lam Chan
08/30/2023, 4:19 PMLuke Dziurzynski
08/30/2023, 5:20 PMNok Lam Chan
08/30/2023, 5:58 PMCould I pass in database tablenames as params and then read from those tables during my kedro pipeline? (edited)The above approach to inject params should work