diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py
index b28e02f..d209237 100644
--- a/dags/fin_porfel.py
+++ b/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: