Langflow 系列 | 第 25 篇:队列、异步任务与并发执行

上一篇分析了日志、监控与 Tracing。那些能力解决的是“运行之后如何排查”的问题,而这一篇要继续往前看:

当用户点击 Run,Langflow 是如何把一次 Flow 构建变成异步任务的?事件如何从后端传到前端?为什么有 streaming、polling、direct 三种模式?多 worker 部署时为什么需要 Redis?Graph 内部又是如何并发执行多个可运行节点的?

这篇文章的核心主题是“调度”。它不像组件开发那样直观,但它决定了 Langflow 在真实生产环境中的运行体验:是否能实时看到节点状态,是否能取消长任务,是否能在多用户和多 worker 场景下稳定返回构建事件。


1. 本篇关注的源码范围

这一篇主要围绕以下源码展开:

主题主要源码
构建 API 路由src/backend/base/langflow/api/v1/chat.py
构建协程主体src/backend/base/langflow/api/build.py
队列服务工厂src/backend/base/langflow/services/job_queue/factory.py</