修改导入顺序
This commit is contained in:
@@ -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}")
|
||||
|
||||
# 提交栅格生成任务
|
||||
|
||||
Reference in New Issue
Block a user