diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py index 95c51cb..7b80857 100644 --- a/dags/split_subkonto2.py +++ b/dags/split_subkonto2.py @@ -308,7 +308,7 @@ def merge_dict_and_split_1C(**kwargs): result_df.to_sql('temp_dict_subkonto_two', con=conn, if_exists='append', index=False, method='multi') conn.execute( ''' - INSERT INTO public.dict_subkonto_two (subkonto2, naimenovanie, nomer, date_begin, date_end) + INSERT INTO public.dict_subkonto_two (subkonto2, nomer, date_begin, date_end) SELECT subkonto2 , nomer