Antigravityマルチエージェント設計の落とし穴と解決策 — 本番環境で詰まる7つの問題

// ❌ 間違い: コンテキストが自動で共有されると思い込む
const agentA = new AntigravityAgent({ name: "DataFetcher" });
const agentB = new AntigravityAgent({ name: "DataAnalyzer" });
 
const dataA = await agentA.run("API からユーザー情報を取得");
// agentB は dataA の結果を「知らない」
const analysis = await agentB.run("ユーザー分析を実行");

// ✓ 正しい: コンテキストを明示的にパス
const agentA = new AntigravityAgent({ name: "DataFetcher" });
const agentB = new AntigravityAgent({ name: "DataAnalyzer" });
 
const resultA = await agentA.run("API からユーザー情報を取得");
 
// agentA の出力を agentB のコンテキストに追加
const contextB = {
  userData: resultA.output,
  timestamp: new Date().toISOString()
};
 
const analysis = await agentB.run(
  "ユーザー分析を実行",
  { context: contextB }
);

const orchestrator = new AgentOrchestrator({
  agents: [
    { name: "Fetcher", agent: agentA },
    { name: "Analyzer", agent: agentB }
  ]
});
 
const result = await orchestrator.execute([
  { agentName: "Fetcher", task: "API からユーザー情報を取得" },
  { 
    agentName: "Analyzer", 
    task: "ユーザー分析を実行",
    dependsOn: "Fetcher"
  }
]);

// ❌ デフォルト Loop Detection: 短すぎる場合がある
const agent = new AntigravityAgent({
  // loopDetection: { maxRepetitions: 3 }
});
 
await agent.run("複雑な多ステップ処理");

// ✓ 正しい: 多ステップワークフロー向けに調整
const agent = new AntigravityAgent({
  loopDetection: {
    maxRepetitions: 5,
    cooldownMs: 2000,
    similarityThreshold: 0.9
  }
});
 
await agent.run("複雑な多ステップ処理");

// ❌ 短すぎる: 外部 API コール含む場合
const agent = new AntigravityAgent({
  timeout: 10000
});

// ✓ 正しい: タスク単位でタイムアウトを調整
const quickTask = await agent.run(
  "このテキストを翻訳してください",
  { timeout: 5000 }
);
 
const complexTask = await agent.run(
  "複数の API からデータ取得して統計分析",
  { 
    timeout: 60000,
    retryOnTimeout: true,
    maxRetries: 2
  }
);

// ❌ 危険: 並列実行で共有リソースへのアクセスがロックされない
const [result1, result2] = await Promise.all([
  agent1.run("データベースの count 値を +1"),
  agent2.run("データベースの count 値を +1")
]);

// ✓ 正しい: 並列化できる部分だけ並列化
const [userData, analyticsData] = await Promise.all([
  agent1.run("ユーザーマスターデータ取得"),
  agent2.run("分析用データ取得")
]);
 
await agent3.run("統合してDB更新", {
  context: { userData, analyticsData }
});

// ❌ 非効率: 全て Planning Mode
const results = [];
for (const item of items) {
  results.push(
    await agent.run(`${item} を処理してください`, {
      mode: "planning"
    })
  );
}

// ✓ 正しい: 軽いタスクは Fast Mode、結果はキャッシュ
const cache = new Map();
 
for (const item of items) {
  const cacheKey = hashFunction(item);
  
  if (cache.has(cacheKey)) {
    results.push(cache.get(cacheKey));
    continue;
  }
  
  const mode = item.split(' ').length > 20 ? "planning" : "fast";
  
  const result = await agent.run(`${item} を処理してください`, {
    mode
  });
  
  cache.set(cacheKey, result);
  results.push(result);
}

// ❌ 危険: 1つが失敗すると全て失敗
const results = await orchestrator.execute([
  { agentName: "A", task: "タスク A" },
  { agentName: "B", task: "タスク B" },
  { agentName: "C", task: "タスク C" }
]);

// ✓ 正しい: 部分的な失敗を許容
const results = await orchestrator.execute([
  { 
    agentName: "A", 
    task: "タスク A",
    errorHandling: "critical"
  },
  { 
    agentName: "B", 
    task: "タスク B",
    errorHandling: "warn"
  },
  { 
    agentName: "C", 
    task: "タスク C",
    errorHandling: "silent"
  }
], {
  continueOnError: true
});

// ❌ デバッグ不可: 何が起きているか不明
const result = await agent.run(task);

// ✓ 正しい: 詳細ログ出力
const agent = new AntigravityAgent({
  logging: {
    level: "debug",
    format: "json",
    destination: "cloudwatch"
  },
  tracing: {
    enabled: true,
    samplingRate: 1.0,
    exportTo: "jaeger"
  }
});