diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py index a15c010..def5b14 100644 --- a/dags/fin_porfel.py +++ b/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 'Список обновлен.'