diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py
index 19c9de1..8a82d9b 100644
--- a/dags/fin_porfel.py
+++ b/dags/fin_porfel.py
@@ -45,6 +45,7 @@ def upsert_list_fin_portfel(**kwargs):
         on fp.schet = osv.schet
         and fp.subkonto2 = osv.subkonto2
     where (osv.schet like '%%01%%' or osv.schet like '%%03%%')
+    and fp.subkonto2 is null
     """
     df = pd.read_sql(query, engine)