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