From 2708c60fea230ccd79db3d9563b60ab49c58dcce Mon Sep 17 00:00:00 2001
From: bn_user <user@example.com>
Date: Wed, 10 Sep 2025 08:21:45 +0000
Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?=
 =?UTF-8?q?=D1=8C=20dags/fin=5Fporfel.py?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dags/fin_porfel.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py
index 8a82d9b..79fccc7 100644
--- a/dags/fin_porfel.py
+++ b/dags/fin_porfel.py
@@ -41,7 +41,7 @@ def upsert_list_fin_portfel(**kwargs):
         , null as summa_dogovora
         , null as percent_value
     from public.oborotno_salbdovaya_vedomostb osv
-    left join public.fin_portfel fp
+    left join public.fin_porfel fp
         on fp.schet = osv.schet
         and fp.subkonto2 = osv.subkonto2
     where (osv.schet like '%%01%%' or osv.schet like '%%03%%')
@@ -51,17 +51,17 @@ def upsert_list_fin_portfel(**kwargs):
 
     with engine.begin() as conn:
         if not df.empty:
-            conn.execute("CREATE TEMP TABLE temp_fin_portfel as SELECT * FROM public.fin_portfel WHERE 1=0")
+            conn.execute("CREATE TEMP TABLE temp_fin_porfel as SELECT * FROM public.fin_porfel WHERE 1=0")
             df.to_sql('temp_fin_portfel', con=conn, if_exists='append', index=False, method='multi')
             conn.execute
             ("""
-            INSERT INTO public.fin_portfel
+            INSERT INTO public.fin_porfel
             SELECT
                   schet
                 , subkonto2
                 , summa_dogovora
                 , percent_value
-            FROM temp_fin_portfel
+            FROM temp_fin_porfel
             """)
             return 'Список обновлен.'
         else: