Check for dry_weather_flow value on migration

nens · Jun 4, 2024 · 99d8ee0 · 99d8ee0
1 parent 0154b0c
commit 99d8ee0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/threedi_schema/migrations/versions/0223_upgrade_db_inflow.py b/threedi_schema/migrations/versions/0223_upgrade_db_inflow.py
@@ -202,7 +202,8 @@ def fix_dry_weather_flow_geometries(src_table):
              f"JOIN {src_table}_map ON v2_connection_nodes.id = {src_table}_map.connection_node_id "
              f"WHERE {src_table}.id = {src_table}_map.{src_table.strip('v2_')}_id "
              f"AND {src_table}.the_geom IS NULL "
-             f"AND {src_table}.nr_of_inhabitants > 0;")
+             f"AND {src_table}.nr_of_inhabitants > 0 "
+             f"AND {src_table}.dry_weather_flow > 0;")
     op.execute(sa.text(query))