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: