Commit b7c88bdb authored by 杨明橙's avatar 杨明橙

修改定时请求报价任务

parent b78afb29
......@@ -205,7 +205,8 @@ class CMCPrice:
try:
logger.info(f'[开始更新] [{symbol}]')
last_data = await self.query_last_data(symbol)
start_time = last_data['time']
# 兼容没有数据 以init方式更新
start_time = last_data['time'] if last_data else (await self.query_added_date(symbol))
# 新建进度
logger.info(f'[更新数据] [{symbol}] [从{start_time}开始]')
await self.start_task(symbol, start_time)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment