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}") # 提交栅格生成任务