taskflow-inbox-triage

TaskFlow 受信トレイの仕分け

これは、コアランタイムをDSLにせずにTaskFlowをどのように考えるかの具体例です。

目標

1つのオーナーフローで受信トレイアイテムを仕分けします：

• ビジネス -> Slackに投稿し、返信を待つ
• 個人 -> すぐにオーナーに通知する
• その他 -> 終日のサマリー用に保持する

パターン

1. 受信トレイバッチ用に1つのフローを作成する。
2. 1つのdetachedタスクを実行して新しいアイテムを分類する。
3. ルーティング状態をstateJsonに永続化する。
4. 外部からの返信が必要な場合にのみwaiting状態に移行する。
5. 分類または人間の入力が完了したらフローを再開する。
6. バッチのルーティングが完了したら終了する。

推奨される stateJson の構造

{
  "businessThreads": [],
  "personalItems": [],
  "eodSummary": []
}

Slackでブロックされたときの推奨される waitJson：

{
  "kind": "reply",
  "channel": "slack",
  "threadKey": "slack:thread-1"
}

最小限のランタイム呼び出し

const taskFlow = api.runtime.tasks.flow.fromToolContext(ctx);

const created = taskFlow.createManaged({
  controllerId: "my-plugin/inbox-triage",
  goal: "triage inbox",
  currentStep: "classify",
  stateJson: {
    businessThreads: [],
    personalItems: [],
    eodSummary: [],
  },
});

const child = taskFlow.runTask({
  flowId: created.flowId,
  runtime: "acp",
  childSessionKey: "agent:main:subagent:classifier",
  task: "Classify inbox messages",
  status: "running",
  startedAt: Date.now(),
  lastEventAt: Date.now(),
});

if (!child.created) {
  throw new Error(child.reason);
}

const waiting = taskFlow.setWaiting({
  flowId: created.flowId,
  expectedRevision: created.revision,
  currentStep: "await_business_reply",
  stateJson: {
    businessThreads: ["slack:thread-1"],
    personalItems: [],
    eodSummary: [],
  },
  waitJson: {
    kind: "reply",
    channel: "slack",
    threadKey: "slack:thread-1",
  },
});

if (!waiting.applied) {
  throw new Error(waiting.code);
}

const resumed = taskFlow.resume({
  flowId: waiting.flow.flowId,
  expectedRevision: waiting.flow.revision,
  status: "running",
  currentStep: "route_items",
  stateJson: waiting.flow.stateJson,
});

if (!resumed.applied) {
  throw new Error(resumed.code);
}

taskFlow.finish({
  flowId: resumed.flow.flowId,
  expectedRevision: resumed.flow.revision,
  stateJson: resumed.flow.stateJson,
});

関連例

• skills/taskflow/examples/inbox-triage.lobster