diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py
index 09957da..200b78d 100644
--- a/dags/split_subkonto2.py
+++ b/dags/split_subkonto2.py
@@ -254,7 +254,7 @@ def read_dict_subkonto2_db(**kwargs):
     from public.oborotno_salbdovaya_vedomostb osv 
     left join public.dict_subkonto_two as dst 
         on dst.subkonto2 = osv.subkonto2
-    where osv.subkonto2 not in (select dst2.subkonto2  from dict_subkonto_two dst2)
+    where osv.subkonto2 not in (select dst2.subkonto2  from public.dict_subkonto_two dst2)
         and (osv.nomer is null or osv.date_begin is null or osv.date_end is null)
     """, engine)
     return df.to_dict(orient='records')
@@ -265,7 +265,7 @@ def split_subkonto_from_1C(**kwargs):
     select distinct
         osv.subkonto2 as subkonto2
     from public.oborotno_salbdovaya_vedomostb osv
-    where osv.subkonto2 not in (select dst2.subkonto2  from dict_subkonto_two dst2)
+    where osv.subkonto2 not in (select dst2.subkonto2  from public.dict_subkonto_two dst2)
     """, engine)
     result_df = df['subkonto2'].apply(parse_contract_cell)
     return result_df.to_dict(orient='records')
@@ -304,7 +304,7 @@ def merge_dict_and_split_1C(**kwargs):
     engine = get_db_engine()
     with engine.begin() as conn:
         #conn.exucute('CREATE TEMP TABLE temp_dict_subkonto_two as SELECT * FROM public.dict_subkonto_two where 1=0')
-        result_df.to_sql('public.dict_subkonto_two', con=conn, if_exists='append', index=False, method='multi')
+        result_df.to_sql('dict_subkonto_two', con=conn, if_exists='append', index=False, method='multi')
         #conn.execute('INSERT INTO public.dict_subkonto_two SELECT * FROM temp_dict_subkonto_two')
     
     return result_df.to_dict('Данные загружены!')