diff --git a/dozer-sql/src/pipeline_builder/from_builder.rs b/dozer-sql/src/pipeline_builder/from_builder.rs
index 8f4a32608f..c1199863ba 100644
--- a/dozer-sql/src/pipeline_builder/from_builder.rs
+++ b/dozer-sql/src/pipeline_builder/from_builder.rs
@@ -76,7 +76,7 @@ fn insert_table_to_pipeline(
 
         Ok(ConnectionInfo {
             processor_name: product_processor_name.clone(),
-            input_nodes: vec![],
+            input_nodes: connection_info.input_nodes,
             output_node: (product_processor_name, DEFAULT_PORT_HANDLE),
         })
     } else {