Add sql delete statements for buses wirh carrier H2

openego · Jan 20, 2025 · 1957c8c · 1957c8c
1 parent 77ca472
commit 1957c8c
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/egon/data/datasets/hydrogen_etrago/bus.py b/src/egon/data/datasets/hydrogen_etrago/bus.py
@@ -47,7 +47,15 @@ def insert_hydrogen_buses(scn_name):
 
     sources = config.datasets()["etrago_hydrogen"]["sources"]
     target_buses = config.datasets()["etrago_hydrogen"]["targets"]["hydrogen_buses"] 
-    h2_buses = initialise_bus_insertion('H2', target_buses, scenario = scn_name)
+    h2_buses = initialise_bus_insertion('H2_grid', target_buses, scenario = scn_name)
+
+    db.execute_sql(
+        f"""
+        DELETE FROM {target_buses['schema']}.{target_buses['table']}
+        WHERE scn_name = '{scn_name}'
+        AND carrier = 'H2' AND country = 'DE'
+        """
+    )
 
     h2_buses.x = h2_input.x
     h2_buses.y = h2_input.y