修复创建任务时无节点
This commit is contained in:
parent
86fd419f6e
commit
4adcc89403
|
@ -141,7 +141,9 @@ async def get_redis_online_data(redis_con):
|
||||||
update_time_str = hash_data.get('updateTime')
|
update_time_str = hash_data.get('updateTime')
|
||||||
if update_time_str:
|
if update_time_str:
|
||||||
update_time = datetime.strptime(update_time_str, '%Y-%m-%d %H:%M:%S')
|
update_time = datetime.strptime(update_time_str, '%Y-%m-%d %H:%M:%S')
|
||||||
time_difference = (datetime.strptime(get_now_time(), "%Y-%m-%d %H:%M:%S") - update_time).seconds
|
time_difference = (
|
||||||
|
datetime.strptime(get_now_time(), "%Y-%m-%d %H:%M:%S") - update_time).total_seconds()
|
||||||
|
logger.info(f'节点时间差:{time_difference}, {get_now_time()}, {update_time}')
|
||||||
if time_difference > NODE_TIMEOUT:
|
if time_difference > NODE_TIMEOUT:
|
||||||
await asyncio.create_task(update_redis_data(redis, key))
|
await asyncio.create_task(update_redis_data(redis, key))
|
||||||
hash_data['state'] = '3'
|
hash_data['state'] = '3'
|
||||||
|
|
Loading…
Reference in New Issue