diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py index 86340d5..870464a 100644 --- a/dags/split_subkonto2.py +++ b/dags/split_subkonto2.py @@ -317,7 +317,7 @@ def merge_dict_and_split_1C(**kwargs): FROM temp_dict_subkonto_two''' ) - return result_df.to_dict('Данные загружены!') + return 'Данные загружены!' with DAG( dag_id='split_subkonto2',