Обновить dags/poruchitelstva.py

This commit is contained in:
bn_user 2025-12-05 12:34:14 +00:00
parent 337207cbf5
commit 1846ea48f5
1 changed files with 3 additions and 4 deletions

View File

@ -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