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

dags/fin_porfel.py

@@ -44,9 +44,9 @@ def upsert_list_fin_portfel(**kwargs):
     from public.oborotno_salbdovaya_vedomostb osv
     left join public.fin_porfel fp
         on fp.schet = osv.schet
-        and fp.subkonto2 = osv.subkonto2
+        and fp.uid_dogovor = osv.uid_dogovor
     where (osv.schet like '%%01%%' or osv.schet like '%%03%%')
-    and fp.subkonto2 is null
+    and fp.uid_dogovor is null
     """
     df = pd.read_sql(query, engine)
     with engine.begin() as conn: