Initial simpledb

OpenBudget · Jun 24, 2024 · c247933 · c247933
1 parent 81b336d
commit c247933
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datapackage_pipelines_budgetkey/pipelines/simpledb/process.py b/datapackage_pipelines_budgetkey/pipelines/simpledb/process.py
@@ -138,8 +138,8 @@ def get_flow(table, params):
 
     steps.append(DF.select_fields(field_names))
     steps.append(DF.dump_to_path(f'/var/datapackages/simpledb/{table}'))
-    steps.append(DF.dump_to_sql({table: {'resource-name': table}})
-)
+    steps.append(DF.dump_to_sql({table: {'resource-name': table}}))
+    return DF.Flow(*steps)
 
 def flow(parameters, *_):
     for table, params in PARAMETERS.items():