From 1846ea48f56626b1442d59831930137a1c9fc1d1 Mon Sep 17 00:00:00 2001 From: bn_user Date: Fri, 5 Dec 2025 12:34:14 +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/poruchitelstva.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dags/poruchitelstva.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/dags/poruchitelstva.py b/dags/poruchitelstva.py index 65c8c70..d9c4f2d 100644 --- a/dags/poruchitelstva.py +++ b/dags/poruchitelstva.py @@ -179,11 +179,10 @@ def update_poruchitelstva_structure_with_detailed_errors(**kwargs): check_result = conn.execute(""" SELECT (SELECT COUNT(*) FROM poruchitelstva) as main_table_count, - (SELECT COUNT(*) FROM poruchitelstva_normalized) as normalized_count, (SELECT COUNT(DISTINCT column_name) - 7 - FROM information_schema.columns - WHERE table_name = 'poruchitelstva' - AND table_schema = 'public') as company_columns_count + FROM information_schema.columns + WHERE table_name = 'poruchitelstva' + AND table_schema = 'public') as company_columns_count """).fetchone() main_count, normalized_count, company_cols = check_result