Обновить dags/fin_porfel.py
This commit is contained in:
parent
1455464fc1
commit
a62b729e3c
|
|
@ -48,7 +48,6 @@ def upsert_list_fin_portfel(**kwargs):
|
||||||
and fp.subkonto2 is null
|
and fp.subkonto2 is null
|
||||||
"""
|
"""
|
||||||
df = pd.read_sql(query, engine)
|
df = pd.read_sql(query, engine)
|
||||||
return df.to_dict(orient='records')
|
|
||||||
with engine.begin() as conn:
|
with engine.begin() as conn:
|
||||||
if not df.empty:
|
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 as SELECT * FROM public.fin_porfel WHERE 1=0")
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue