Python Telegram Bot JobQueue无法执行return问题求助

核心问题点 #

1. 异步时序错误：调用job.run()后立即读取job.data['result']，此时check_who_likes还没执行完，拿到的永远是初始的None，导致return SHOW_WHO_LIKES永远不会触发，定时任务持续重复。
2. 上下文混淆：
   • 嵌套函数check_who_likes中修改的是context.user_data['result']，但外部试图读取的是job.data['result']，两者不是同一个对象，根本拿不到更新后的值。
   • 直接复用外部的update对象到定时任务中，后续任务运行时update的上下文已失效，可能引发未知问题。
3. 资源释放不严谨：finally块中直接关闭cursor和conn，如果连接获取失败，cursor未初始化会抛出异常。

修复后的代码 #

async def matching(update: Update, context: CallbackContext):
    user_id = update.message.from_user.id
    # 存储任务ID，方便后续取消
    context.user_data['matching_job_id'] = None

    async def check_who_likes(context: CallbackContext):
        cursor = None
        conn = None
        try:
            conn = connection_pool.get_connection()
            cursor = conn.cursor()
            cursor.execute("SELECT LikeUserID FROM Likes WHERE LikedUserID = %s", (user_id,))
            likes = cursor.fetchall()
            if len(likes) > 0:
                await update.message.reply_text(f"{len(likes)}")
                # 标记任务完成
                context.user_data['result'] = True
                # 取消定时任务
                current_job = context.job
                if current_job:
                    current_job.schedule_removal()
                # 触发状态跳转，这里直接调用目标状态逻辑即可
                await show_who_likes(update, context)
        except Exception as e:
            # 不要吞异常，打印错误方便调试
            print(f"检查点赞列表出错: {str(e)}")
        finally:
            if cursor:
                cursor.close()
            if conn:
                conn.close()
            await asyncio.sleep(1)

    # 创建定时任务
    job = context.job_queue.run_repeating(check_who_likes, interval=10, first=0)
    context.user_data['matching_job_id'] = job.job_id

关键修复说明 #

• 异步逻辑调整：把状态跳转逻辑移到check_who_likes内部，检测到点赞后立即取消定时任务并触发后续操作，避免外部函数提前结束无法感知任务结果。
• 上下文统一：用context.user_data存储任务状态和任务ID，确保内外逻辑共享状态；同时使用稳定的对话ID替代可能过期的update对象。
• 资源安全释放：关闭cursor和conn前先判断是否存在，避免空指针异常；保留错误打印便于排查问题。
• 任务管理：存储任务ID，方便后续用户主动取消任务时定位到对应定时任务。

内容的提问来源于stack exchange，提问作者Arda Senoglu