From f5cee91f743cd1d9c1c24642b484305d3900976b Mon Sep 17 00:00:00 2001 From: bn_user Date: Mon, 8 Dec 2025 10:21:13 +0000 Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?= =?UTF-8?q?=D1=8C=20dags/OSV=5Fwith=5Fdocs.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dags/OSV_with_docs.py | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) 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 'Список обновлен.'