diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index 8afbdfa..70aec56 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -373,6 +373,17 @@ 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 + , '00000000-0000-0000-0000-000000000000' 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 lizingi_garantii 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: