Обновить dags/OSV_with_docs.py

dags/OSV_with_docs.py

@@ -401,15 +401,8 @@ def poruchitelstva(**kwargs):
             #     date_begin = EXCLUDED.date_begin,
             #     date_end = EXCLUDED.date_end
             conn.execute("""
-            UPDATE public.poruchitelstva fp
+            DELETE FROM public.poruchitelstva fp
-            SET id = subquery.new_id
+            WHERE fp.uid_dogovor is null
-            FROM (
-                SELECT 
-                    id,
-                    ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id
-                FROM public.poruchitelstva
-            ) AS subquery
-            WHERE fp.id = subquery.id;
             """
             )
             return 'Список обновлен.'