diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index 6e3d1de..8afbdfa 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -365,7 +365,7 @@ def poruchitelstva(**kwargs): UNION ALL SELECT case when osv.category_name = 'Лизинг' then '76.07.1' else '76.09' end as schet - , osv.id::text as uid_dogovor + , '00000000-0000-0000-0000-000000000000' as uid_dogovor , osv.category_name as name , osv.agreement_num as nomer , osv.agreement_date as date_begin @@ -373,17 +373,6 @@ def poruchitelstva(**kwargs): FROM lizingi_garantii osv LEFT JOIN poruchitelstva p on p.nomer = osv.agreement_num WHERE p.uid_dogovor is null - UNION ALL - SELECT - '009' as schet - , osv.id::text as uid_dogovor - , osv.category_name as name - , osv.agreement_num as nomer - , osv.agreement_date as date_begin - , osv.redemption_date as date_end - FROM zalogi osv - LEFT JOIN poruchitelstva p on p.nomer = osv.agreement_num - WHERE p.uid_dogovor is null """) df = pd.read_sql(query, engine) with engine.begin() as conn: