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

dags/fin_porfel.py

@@ -71,7 +71,14 @@ def upsert_list_fin_portfel(**kwargs):
             )
             conn.execute("""
             UPDATE public.fin_porfel fp
-            SET fp.id = row_number() over (order by uid_dogovor, schet, summa_dogovora)
+            SET id = subquery.new_id
+            FROM (
+                SELECT 
+                    id,
+                    ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, summa_dogovora) as new_id
+                FROM public.fin_porfel
+            ) AS subquery
+            WHERE fp.id = subquery.id;
             """
             )
             return 'Список обновлен.'