/images/hugo/avatar.png

pregel 重要流程总结

本节我们总结回顾一下 Pregel 重要流程,包括 PregelLoop 的更新循环 PregelLoop 的崩溃恢复 中断执行流程,包括父图发生中断、子图发生中断 1. PregelLoop 的更新循环 1.1 任务生成 prepare_next_tasks 会生成两种

pregel 的可配置项

1. configurable 配置 pregel 的实现在 RunnableConfig configurable 配置段中预定义了很多配置项。这些配置项对应我们理解 pregel 有很重要的作用。 以下是 LangGraph 中预定义的 configurable 配置键(CONFIG_KEY_

pregel loop - 2

上一节我们介绍了 pregel loop 的初始化、tick 函数。tick 函数其实也没有介绍完,并标记了我们要理解的其他方法,包括: _emit _put_checkpoint put_writes 这一节我们来学习这些函数

pregel algo - 2

前面我们介绍了 _algo.py 中关联的对象,这一节我们来介绍 _algo.py 的这几个核心函数: prepare_single_task prepare_next_tasks local_read apply_writes 1. prepare_next_tasks 1.1 prepare_next_tasks 入参 prepare_next_tasks 函数的定义如下: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18

pregel executor

executor 是 langgraph 中对任务池的抽象。分为同步和异步两个实现。 1. BackgroundExecutor BackgroundExecutor 是一个基于线程池的上下文管理器,用于在后台并行运行多个同步任务(函数),并在退出上下文