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

2025-09-10 08:22:45 +00:00 · 2025-09-10 08:22:45 +00:00 · dec1637c4b
parent 2708c60fea
commit dec1637c4b
1 changed files with 1 additions and 1 deletions
--- a/dags/fin_porfel.py
+++ b/dags/fin_porfel.py
@ -48,7 +48,7 @@ def upsert_list_fin_portfel(**kwargs):
    and fp.subkonto2 is null
    """
    df = pd.read_sql(query, engine)
-
+    return df.to_dict(orient='records')
    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")