fixed syntax error in code block for parameterized_subdag

DAGWorks-Inc · Oct 8, 2024 · 05cf57d · 05cf57d
1 parent 69c94cc
commit 05cf57d
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/hamilton/function_modifiers/recursive.py b/hamilton/function_modifiers/recursive.py
@@ -499,10 +499,10 @@ class parameterized_subdag(base.NodeCreator):
 
         @parameterized_subdag(
             feature_modules,
-            from_datasource_1={"inputs" : {"data" : value("datasource_1.csv"}},
-            from_datasource_2={"inputs" : {"data" : value("datasource_2.csv"}},
+            from_datasource_1={"inputs" : {"data" : value("datasource_1.csv")}},
+            from_datasource_2={"inputs" : {"data" : value("datasource_2.csv")}},
             from_datasource_3={
-                "inputs" : {"data" : value("datasource_3.csv"},
+                "inputs" : {"data" : value("datasource_3.csv")},
                 "config" : {"filter" : "only_even_client_ids"}
             }
         )
@@ -522,10 +522,10 @@ def feature_engineering(feature_df: pd.DataFrame) -> pd.DataFrame:
             inputs={"data" : value("datasource_1.csv")},
             from_datasource_1={},
             from_datasource_2={
-                    "inputs" : {"data" : value("datasource_2.csv"}
+                    "inputs" : {"data" : value("datasource_2.csv")}
             },
             from_datasource_3={
-                    "inputs" : {"data" : value("datasource_3.csv"},
+                    "inputs" : {"data" : value("datasource_3.csv")},
                     "config" : {"filter" : "only_even_client_ids"},
             }
         )