diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index 13ec31a..fcef4ce 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -401,15 +401,8 @@ def poruchitelstva(**kwargs): # date_begin = EXCLUDED.date_begin, # date_end = EXCLUDED.date_end conn.execute(""" - UPDATE public.poruchitelstva fp - SET id = subquery.new_id - FROM ( - SELECT - id, - ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id - FROM public.poruchitelstva - ) AS subquery - WHERE fp.id = subquery.id; + DELETE FROM public.poruchitelstva fp + WHERE fp.uid_dogovor is null """ ) return 'Список обновлен.'