diff --git a/src/graph/dynamic/mod.rs b/src/graph/dynamic/mod.rs index 535dd32..06f0f79 100644 --- a/src/graph/dynamic/mod.rs +++ b/src/graph/dynamic/mod.rs @@ -23,7 +23,7 @@ mod read_map; #[derive(Serialize, Deserialize, Clone, JsonSchema)] pub struct DynamicNode { pub wasm_file_path: String, - pub input_file_paths: Vec, + pub input_file_paths: HashMap, pub output_file: String, } @@ -46,7 +46,7 @@ impl RunnableNode for DynamicNodeRunner { ); let bindings = Dynamic::instantiate(&mut store, &component, &linker)?; let read_map = store.data_mut().resources.push(ReadMapData { data: HashMap::new() })?; - let readers = store.data_mut().resources.push(CsvReadersData { readers: HashMap::new() })?; + let readers = store.data_mut().resources.push(CsvReadersData { readers: self.dynamic_node.input_file_paths.clone() })?; let writer = CsvWriterData::new(self.dynamic_node.output_file.clone())?; let writer = store.data_mut().resources.push(writer)?; bindings.call_evaluate(&mut store, read_map, readers, writer)?;