Python 异步的传染性；
每次看到await都有点乱，实际是因为它的传染性，必须写，不然只会返回协程对象
# 最底层：真实IO
async def call_llm():await httpx.post(...) # 真正的让出点# 中间层：必须 async def + await，否则无法传递让出
async def run_rag_pipeline():result = await call_llm() # 如果这里不await，call_llm()只返回协程对象，不执行return result# 上层：同样
async def handle_request():result = await run_rag_pipeline()return result
如果中间某一层断掉：
python# ❌ 中间层忘了 await
async def run_rag_pipeline():result = call_llm() # 返回一个协程对象，没有执行！return result # result 是 <coroutine object>，不是真实结果
langgragh并行工作流；
将子任务拆分并并行运行，但是有个问题：我是用生产消费模式，让一个worker拿到这个pipeline，这个还是真正的并行吗。
通过并行化，这可以通过同时运行多个独立的子任务，或者多次运行同一任务以检查不同的输出来实现。
并行化通常用于：
- 将子任务拆分并并行运行，这样可以提高速度。
- 多次运行任务以检查不同的输出，这可以提高置信度。
langgragh并行工作流的实现是：asyncio.gather
其实就是：并行的协程全部启动，各自执行到内部第一个 await（发出HTTP请求LLM调用）
call_llm_2 响应回来 → 恢复执行 → 执行完毕 → 继续等其他两个
call_llm_1 响应回来 → 恢复执行 → 执行完毕 → 继续等
call_llm_3 响应回来 → 恢复执行 → 执行完毕→ 三个全部完成，gather 返回 [result1, result2, result3]
→ 调用方拿回执行权，继续往下走