ワークフロー（レガシー）API

const workflows = await mastraClient.getLegacyWorkflows();

const workflow = mastraClient.getLegacyWorkflow("workflow-id");

const details = await workflow.details();

const { runId } = workflow.createRun();
 
const result = await workflow.startAsync({
  runId,
  triggerData: {
    param1: "value1",
    param2: "value2",
  },
});

const { runId } = createRun({ runId: prevRunId });
 
const result = await workflow.resumeAsync({
  runId,
  stepId: "step-id",
  contextData: { key: "value" },
});

try {
  // workflowインスタンスを取得
  const workflow = mastraClient.getLegacyWorkflow("workflow-id");
 
  // workflow実行を作成
  const { runId } = workflow.createRun();
 
  // workflow実行を監視
  workflow.watch({ runId }, (record) => {
    // 新しいレコードはすべてworkflow実行の最新の遷移状態です
 
    console.log({
      activePaths: record.activePaths,
      results: record.results,
      timestamp: record.timestamp,
      runId: record.runId,
    });
  });
 
  // workflow実行を開始
  workflow.start({
    runId,
    triggerData: {
      city: "New York",
    },
  });
} catch (e) {
  console.error(e);
}

try {
  //ステップが中断されている場合にworkflow実行を再開するには
  const { run } = createRun({ runId: prevRunId });
 
  //実行を監視
  workflow.watch({ runId }, (record) => {
    // 新しいレコードはすべてworkflow実行の最新の遷移状態です
 
    console.log({
      activePaths: record.activePaths,
      results: record.results,
      timestamp: record.timestamp,
      runId: record.runId,
    });
  });
 
  //実行を再開
  workflow.resume({
    runId,
    stepId: "step-id",
    contextData: { key: "value" },
  });
} catch (e) {
  console.error(e);
}