diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index 4e3525b..f0d14e5 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -331,18 +331,18 @@ def pogasheniya(**kwargs): date_begin = EXCLUDED.date_begin, date_end = EXCLUDED.date_end """) - # conn.execute(""" - # UPDATE public.pogasheniya fp - # SET id = subquery.new_id - # FROM ( - # SELECT - # id, - # ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id - # FROM public.pogasheniya - # ) AS subquery - # WHERE fp.id = subquery.id; - # """ - # ) + conn.execute(""" + UPDATE public.pogasheniya fp + SET id = subquery.new_id + FROM ( + SELECT + id, + ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id + FROM public.pogasheniya + ) AS subquery + WHERE fp.id = subquery.id; + """ + ) return 'Список обновлен.' else: return 'Обновлять нечего.'