diff --git a/src/scheduler/mod.rs b/src/scheduler/mod.rs index 8e586f5a0..74a3fb2bb 100644 --- a/src/scheduler/mod.rs +++ b/src/scheduler/mod.rs @@ -211,8 +211,10 @@ impl Scheduler { let mut output_mapping: HashMap = HashMap::new(); for name in extractor.outputs.keys() { - let table_name = extraction_policy.output_table_mapping.get(name).unwrap(); - output_mapping.insert(name.clone(), table_name.clone()); + let table_name = extraction_policy.output_table_mapping.get(name); + if let Some(table_name) = table_name { + output_mapping.insert(name.clone(), table_name.clone()); + } } let mut hasher = DefaultHasher::new();