Task 与 Call

​

task 的输入

{
  "task_id": "3f2b1c9e8a4d4c1e9b0a6f7e5d4c3b2a",
  "functionCallConfig": {
    "type": "InputsCallConfig",
    "config": {
      "function": "",
      "code": { "sourceCode": "def _(name):\n    return {\"message\": f\"hello, {name}\"}\n" },
      "callList": [["ct2"], ["blockx"]]
    }
  },
  "resultHandler": { "type": "ReturnValueHandler", "config": {} },
  "taskTimeoutMs": 30000
}

​

call

• 互不依赖、全并行，共享同一时刻的只读世界状态。返回顺序即完成顺序，与 call 列表顺序无关。
• 同一 task 内函数与参数都相同的 call 只执行一次（task 级 result cache 与 singleflight）。
• 单个 call 允许有界重试（DefaultMaxAttempts = 3）；任一根 call 终态失败即整个 task 以 CALL_FAILED 失败（fastFail）。
• 单个 call 的执行预算是 CallDeadlineMs = 5000，只计 CPU 与 IO 后端时间，不含排队。
• 用户函数里的子函数调用（function.call）也是 call，但不进入 outputs，只把结果交还父调用；嵌套深度上限 MaxSubcallDepth = 8。

​

outputs

​

对外状态

​

结果

{
  "success": true,
  "executeResult": {
    "retryable": false,
    "pluginResults": [
      {
        "pluginName": "ReturnValueHandler",
        "success": true,
        "result": [{ "message": "hello, ct2" }, { "message": "hello, blockx" }]
      }
    ]
  }
}

• 不含每个 call 的返回值。只有 ReturnValueHandler 会把整个 outputs 数组放进 pluginResults[i].result；写表插件只返回 written_rows 等统计。
• 失败时用 failureCode 和 retryable 表达。retryable=true 表示 Client 可以用同一份 task 重投；框架自身不做 task 级重试。
• 终态结果在 Worker 上保留 ResultRetentionMs（默认 300000）后清除。Client 用 WatchTasks 流订阅终态，或用 GetTaskResult 轮询。

​

不变量

• 以 task 为中心：读缓存、状态共享、超时都锚定在 task 上，task 结束即释放。
• 单 Worker 执行：一个 task 只在一个 Worker 上跑；Worker 不感知 Coordinator，只暴露 RequestTaskSlot 与 SubmitTask。
• 函数版本固定：task 激活时固定一个代码快照（taskCodeEpoch），之后的所有 call 和子调用都用这份快照；代码热更新只影响新 task。
• 幂等：同一 task_id 处于 RUNNING 或结果仍在保留窗口内时，重复 SubmitTask 返回当前状态，不会再执行一次。
• 不做 task 级自动重试，不支持取消：框架只提供超时；是否重投由 Client 根据 retryable 决定。
• 准入错误不进 TaskResult：slot 无效、无空闲 slot、参数非法、resultHandler.type 未注册等都以 gRPC status 返回；一旦 task 进入 RUNNING，之后的失败都收敛为 FAILED 终态。

​

小结

• task = task_id + Call Builder 配置 + 可选 Writer Plugin 配置 + 可选超时；call = 函数 + 位置参数。
• call 全并行、无顺序、可去重；outputs 是扁平的返回值集合。
• 对外只有 ALLOCATED / RUNNING / SUCCEEDED / FAILED 四个状态；失败用 failureCode + retryable 表达。
• 框架不重试、不取消 task；幂等键是 task_id。

• Task 生命周期：端到端时序、slot 状态机、时间语义速查。
• Call Builder 与 Writer Plugin：functionCallConfig 与 resultHandler 的配置形状。
• 函数代码：call 执行的那段代码长什么样。
• 提交 task 示例：用 blockx-py 或直接调 gRPC 提交 task。