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

dags/split_subkonto2.py

@@ -297,7 +297,12 @@ def merge_dict_and_split_1C(**kwargs):
     result_df['date_end'] = result_df['date_end_dict']
 
     result_df = result_df[['subkonto2', 'naimenovanie', 'nomer', 'date_begin', 'date_end']]
-    return result_df.to_dict(orient='records')
+    
+    engine = get_db_engine()
+    with engine.begin as conn:
+        result_df.to_sql('public.dict_subkonto_two', con=conn, if_exists='append', index=False, method='multi')
+    
+    return result_df.to_dict('Данные загружены!')
 
 with DAG(
     dag_id='split_subkonto2',