Browse Source

Fix: adjust input mappings that refer to single operator nodes

tags/v0.2.0-candidate
Philipp Oppermann 3 years ago
parent
commit
77c4b11c8d
Failed to extract signature
1 changed files with 8 additions and 0 deletions
  1. +8
    -0
      libraries/core/src/descriptor/mod.rs

+ 8
- 0
libraries/core/src/descriptor/mod.rs View File

@@ -46,6 +46,14 @@ impl Descriptor {
NodeKind::Custom(node) => node.run_config.inputs.values_mut().collect(),
NodeKind::Operator(operator) => operator.config.inputs.values_mut().collect(),
};
for mapping in input_mappings.into_iter().filter_map(|m| match m {
InputMapping::Timer { .. } => None,
InputMapping::User(m) => Some(m),
}) {
if let Some(op_name) = single_operator_nodes.get(&mapping.source).copied() {
mapping.output = DataId::from(format!("{op_name}/{}", mapping.output));
}
}

// resolve nodes
let kind = match node.kind {


Loading…
Cancel
Save