30秒超时
This commit is contained in:
@@ -65,7 +65,7 @@ def send_message_in_thread(func, *args, **kwargs):
|
|||||||
# 在共享事件循环中运行任务
|
# 在共享事件循环中运行任务
|
||||||
future = asyncio.run_coroutine_threadsafe(send(), loop)
|
future = asyncio.run_coroutine_threadsafe(send(), loop)
|
||||||
# 等待任务完成,设置超时时间
|
# 等待任务完成,设置超时时间
|
||||||
future.result(timeout=10)
|
future.result(timeout=30)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"消息发送任务执行失败: {e}")
|
logger.error(f"消息发送任务执行失败: {e}")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user