From 4a8130a74869b3b2891f9444012062fea91a44a0 Mon Sep 17 00:00:00 2001
From: DingZQ <zqding@hotmail.com>
Date: Sat, 19 Apr 2025 11:28:57 +0800
Subject: [PATCH] Refine

---
 influxdb_api.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/influxdb_api.py b/influxdb_api.py
index ea89b85..cf7b924 100644
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -1814,8 +1814,8 @@ def store_realtime_simulation_result_to_influxdb(node_result_list: List[Dict[str
             write_api.write(bucket=bucket, org=org_name, record=points_to_write)
             write_api.flush()  # 刷新缓存一次
     except Exception as e:
+        client.close()
         raise RuntimeError(f"数据写入 InfluxDB 时发生错误: {e}")
-		client.close()
 		
     time.sleep(10)
     print("Total points written:", points_written)