diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py index 411a7cb..3c2326f 100644 --- a/dags/pogasheniya.py +++ b/dags/pogasheniya.py @@ -53,7 +53,7 @@ def pogasheniya(**kwargs): , osv.agreement_date , osv.redemption_date FROM lizingi_garantii osv - LEFT JOIN pogasheniya p on p.uid_dogovor = osv.uid_subkonto2 and p.schet = osv.schet and p.nomer = osv.agreement_num + LEFT JOIN pogasheniya p on p.nomer = osv.agreement_num WHERE p.uid_dogovor is null """ df = pd.read_sql(query, engine)