DAG总览 / 组目录 / G22 作业调度

dsh-jobs-local · @deepseek-ai/dsh-jobs-local

Layer 5G22
目录:ACP 协议API 网关与控制器附件启动与插件管理客户端运行时客户端 UI 包上下文压缩上下文注入核心运行时凭据与授权交付物文档处理实验特性宿主扩展反馈通道文件系统目标与计划工具守卫Hooks 扩展宿主服务交互命令作业调度LLM 适配LSP 集成MCP 协议规划模式Agent 预设代码执行运行时运行时诊断沙箱定时调度SDK 与协议会话核心会话检索设置Shell 执行技能溢出存储SSH 远程执行存储子代理子进程终端待办类型契约框架 vendorWeb 访问Webhook工作流工作区
依赖链 · 上游(该插件依赖的前驱):
依赖链 · 下游(依赖该插件的节点):
无下游(叶子/被消费端)
同一拓扑层(Layer 5,层次遍历层序):
↑ Layer 4(13 插件)Layer 5↓ Layer 6(18 插件)

插件信息

包名@deepseek-ai/dsh-jobs-local
分组G22 · 作业调度
拓扑层Layer 5(层次遍历:被依赖方先于依赖方)
源码路径packages/jobs/jobs-local

① 实现逻辑

以进程内内存实现 ctx.jobs 后台作业 seam:LocalJobRegistry 继承 JobRegistry 并用 Map 保存每条作业记录,OutputRing 提供 UTF-8 安全的有界输出环形缓冲与绝对偏移非消耗式读取 (src/ring.ts:38-113),startPump 以有限轮询把作业的 pull 源排入环并在结算后做最终排空 (src/pump.ts:53-106)。JobEventHub 按注册 scope 分层路由注册/输出/进度/结算事件 (src/events.ts:43-93)。start/settle/kill/wait 处理 owner-session 隔离、每 owner 并发上限、首写胜出的结算与 teardown 级联取消 (src/index.ts:206-304, 577-607)。

内部结构动态 DAG(深色主题:橙色=上游依赖 · 绿色=下游依赖 · 棕色=外部seam · 蓝=本插件)
本插件 上游依赖 下游依赖 外部 seam

② 注册/提供(provides)

③ 依赖(depends_on · 上游前驱)

dsh-agentE1+E2
把作业 owner 会话解析为活 Agent 实例并挂接其 scope 清理,实现按 owner 归属与生命周期取消
src/index.ts:15 import type Agent + src/index.ts:359 ctx.get('agents')
dsh-scopeE1
用 scope 分层存放控制器与订阅,使每 owner 的读与通知相对化
src/events.ts:9 import ScopedLayers/scopeOf
dsh-sessionE1
以会话 id 做作业访问隔离鉴权(assertAccess 越权拒绝)
src/index.ts:17 import type SessionId

④ 被依赖(dependents · 下游消费者)

无下游(叶子/被消费端)