diff --git a/dags/split_subkonto2.py b/dags/split_subkonto2.py
index c4d9476..f9aa3a9 100644
--- a/dags/split_subkonto2.py
+++ b/dags/split_subkonto2.py
@@ -266,7 +266,7 @@ def split_subkonto_from_1C(**kwargs):
     from public.oborotno_salbdovaya_vedomostb osv
     where osv.subkonto2 not in (select dst2.subkonto2  from dict_subkonto_two dst2)
     """, engine)
-    result_df = df['column_name'].apply(parse_contract_cell)
+    result_df = df['subkonto2'].apply(parse_contract_cell)
     return result_df.to_dict(orient='records')
 
 def merge_dict_and_split_1C(**kwargs):