Function main

sdk/node/examples/orchestration/parallel-pipeline.mjs:29–51

()

}

async function main() {
  const agent = await Agent.create(repoConfigPath());
  const session = agent.session('.', {});

  // 1. parallel — independent steps; outcomes in input order.
  const outcomes = await session.parallel([
    { taskId: 'langs', agent: 'general', description: 'list', prompt: 'Name three systems languages.', maxSteps: 2 },
    { taskId: 'safe', agent: 'general', description: 'classify', prompt: 'Is Rust memory-safe without a GC? yes/no.', maxSteps: 2 },
  ]);
  for (const o of outcomes) console.log(`[parallel] ${o.taskId}: success=${o.success}`);

  // 2. pipeline — stage 2 builds on stage 1's output. Return null to stop a
  //    chain. A stage callback MUST NOT throw (return null on error).
  const results = await session.pipeline(
    ['the Rust programming language'],
    [
      (ctx) => ({ taskId: 'sum', agent: 'general', description: 'summarize', prompt: `In one sentence, what is ${ctx.item}?`, maxSteps: 2 }),
      (ctx) => ({ taskId: 'cls', agent: 'general', description: 'classify',
                  prompt: `Reply YES or NO: does this describe a programming language?\n\n${ctx.previous.output}`, maxSteps: 2 }),
    ],
  );
  for (const r of results) console.log(`[pipeline] final=${r === null ? null : JSON.stringify(r.output.slice(0, 60))}`);
}

main().catch((err) => {
  console.error(err);