From 9384df1b28c24927c2ec5a6959696043003e9c54 Mon Sep 17 00:00:00 2001
From: wzy-warehouse <18135009705@163.com>
Date: Sat, 30 May 2026 16:07:29 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AF=BC=E5=85=A5=E9=A1=BA?=
 =?UTF-8?q?=E5=BA=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/core/rainfall_manager.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/app/core/rainfall_manager.py b/app/core/rainfall_manager.py
index 36a033f..b916f4e 100644
--- a/app/core/rainfall_manager.py
+++ b/app/core/rainfall_manager.py
@@ -6,7 +6,6 @@ import time
 from datetime import datetime
 from typing import Optional
 
-from app.utils import thread_pool_manager
 from app.utils.logger import get_logger
 
 
@@ -25,6 +24,8 @@ class RainfallManager:
         Args:
             query_time: 查询时间，默认为当前时间
         """
+        from app.utils import thread_pool_manager
+        
         if query_time is None:
             query_time = datetime.now()
         
@@ -55,6 +56,8 @@ class RainfallManager:
                 
                 # 如果ID为空（刚启动）或者改变，则生成降雨栅格
                 if self.last_max_id is None or max_id != self.last_max_id:
+                    from app.utils import thread_pool_manager
+                    
                     self.logger.info(f"检测到数据更新，旧ID: {self.last_max_id}, 新ID: {max_id}")
                     
                     # 提交栅格生成任务