diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py index 438f965..28ef0cd 100644 --- a/dags/split_subkonto2.py +++ b/dags/split_subkonto2.py @@ -326,7 +326,7 @@ def merge_dict_and_split_1C(**kwargs): conn.execute( ''' INSERT INTO public.dict_subkonto_two (schet, subkonto2, nomer, date_begin, date_end) - SELECT + SELECT DISTINCT schet , subkonto2 , nomer