Triagem de Caixa de Entrada TaskFlow

O que Triagem de Caixa de Entrada TaskFlow faz?

Este é um exemplo concreto de como pensar sobre o TaskFlow sem transformar o runtime principal em uma DSL.

Objetivo

Triar itens da caixa de entrada com um fluxo de proprietário único:

• negócios -> postar no Slack e aguardar resposta
• pessoais -> notificar o proprietário agora
• outros -> manter para resumo no final do dia

Padrão

1. Criar um fluxo para o lote da caixa de entrada.
2. Executar uma tarefa destacada para classificar novos itens.
3. Persistir o estado de roteamento em stateJson.
4. Mudar para waiting somente quando uma resposta externa for necessária.
5. Retomar o fluxo quando a classificação ou entrada humana for concluída.
6. Finalizar quando o lote tiver sido roteado.

Forma sugerida de stateJson

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

Forma sugerida de waitJson quando bloqueado no Slack:

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

Chamadas mínimas de runtime

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,
});

Exemplo relacionado

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