diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py index 767e730..a15c010 100644 --- a/dags/fin_porfel.py +++ b/dags/fin_porfel.py @@ -71,7 +71,7 @@ def upsert_list_fin_portfel(**kwargs): ) conn.execute(""" UPDATE public.fin_porfel fp - SET fp.id = row_nubmer() over (order by uid_dogovor, schet, summa_dogovora) + SET fp.id = row_number() over (order by uid_dogovor, schet, summa_dogovora) """ ) return 'Список обновлен.'