Johannes
09/04/2023, 9:36 AMdatajoely
09/04/2023, 9:45 AMJohannes
09/05/2023, 8:45 AMdef DATA_CATALOG(basic_data):
conf_loader = ConfigLoader(conf_source= Path("/workspace/pipeline/src/tests/conf/"))
return DataCatalog(
data_sets={"basic_data": MemoryDataset(basic_data)},
feed_dict=???
)
Unfortunately I cannot use the parameter selection like shown below:
def test_example_pipeline(DATA_CATALOG):
# Initialize Kedro context and runner
runner = SequentialRunner()
#pipe = create_pipeline(inputs = "basic_data", outputs = "outputs")
pipe = pipeline(
[
node(func=increment_random_seed,
inputs={"random_seed": "params:random_seed.option1"},
outputs="output_inrs",
name="split_data"),
node(func=multiply_arr,
inputs={"arr": "basic_data",
"random_seed": "output_inrs"},
outputs="outputs")
],
tags="DL_Pipeline"
How could I solve this?