diff --git a/influxdb_api.py b/influxdb_api.py
index c29db17..5cd8ffe 100644
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -2136,6 +2136,9 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
         jitter_interval=200,  # 添加抖动以避免同时写入
         max_retry_delay=30000  # 最大重试延迟（毫秒）
     )
+
+    print("fill_scheme_simulation_result_to_SCADA")
+
     write_api = client.write_api(write_options=write_options)
     # 创建一个临时存储点数据的列表
     points_to_write = []
@@ -2157,6 +2160,8 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
             points_to_write.append(point)
             # write_api.write(bucket=bucket, org=org_name, record=point)
 
+    print("fill_scheme_simulation_result_to_SCADA 2163")
+
     for key, value in globals.scheme_pipe_flow_ids.items():
         scheme_pipe_flow_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name,
                                                             query_date=query_date, ID=value, type='link', property='flow'))
@@ -2173,6 +2178,8 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
             points_to_write.append(point)
             # write_api.write(bucket=bucket, org=org_name, record=point)
 
+    print("fill_scheme_simulation_result_to_SCADA - 2181")
+
     for key, value in globals.scheme_pressure_ids.items():
         scheme_pressure_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name,
                                                             query_date=query_date, ID=value, type='node', property='pressure'))
@@ -2220,6 +2227,9 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
             )
             points_to_write.append(point)
             # write_api.write(bucket=bucket, org=org_name, record=point)
+
+    print('fill_scheme_simulation_result_to_SCADA - 2231')
+
     # 批量写入数据
     if points_to_write:
         write_api.write(bucket=bucket, org=org_name, record=points_to_write)