diff --git a/layers/water_name/update_water_lakeline.sql b/layers/water_name/update_water_lakeline.sql index 3c58e435..cb62bb2a 100644 --- a/layers/water_name/update_water_lakeline.sql +++ b/layers/water_name/update_water_lakeline.sql @@ -66,7 +66,10 @@ BEGIN INSERT INTO osm_water_lakeline SELECT * FROM osm_water_lakeline_view - WHERE osm_water_lakeline_view.osm_id = NEW.osm_id; + WHERE osm_water_lakeline_view.osm_id = NEW.osm_id + -- May happen in case we replay update + ON CONFLICT ON CONSTRAINT osm_water_point_pk + DO NOTHING; RETURN NULL; END; diff --git a/layers/water_name/update_water_point.sql b/layers/water_name/update_water_point.sql index b954bfce..cfa48614 100644 --- a/layers/water_name/update_water_point.sql +++ b/layers/water_name/update_water_point.sql @@ -66,7 +66,10 @@ BEGIN INSERT INTO osm_water_point SELECT * FROM osm_water_point_view - WHERE osm_water_point_view.osm_id = NEW.osm_id; + WHERE osm_water_point_view.osm_id = NEW.osm_id + -- May happen in case we replay update + ON CONFLICT ON CONSTRAINT osm_water_point_pk + DO NOTHING; RETURN NULL; END;