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

dags/fin_porfel.py

@@ -50,7 +50,7 @@ def upsert_list_fin_portfel(**kwargs):
     df = pd.read_sql(query, engine)
     with engine.begin() as conn:
         if not df.empty:
-            conn.execute("CREATE TEMP TABLE temp_fin_porfel as SELECT * FROM public.fin_porfel WHERE 1=0")
+            conn.execute("CREATE TEMP TABLE temp_fin_porfel (schet text null, subkonto2 text null, summa_dogovora text null, percent_value text null)")
             df.to_sql('temp_fin_porfel', con=conn, if_exists='append', index=False, method='multi')
             conn.execute
             ("""