diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py index 6958781..cba3e9c 100644 --- a/dags/pogasheniya.py +++ b/dags/pogasheniya.py @@ -71,18 +71,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 'Обновлять нечего.'