name: dmux-workflows description: 複数のAIエージェントとタスク集約ワークフローを調整します。複数のワーカーで作業を分配し、エラーを処理し、結果をマージ。 origin: ECC

dmux ワークフロー

複数のエージェントとタスク集約処理の調整。

使用時期

• 複数のタスクを並行して実行
• 大規模なワークフローを調整
• エージェント間でタスクを分配
• エラーハンドリングとリトライ
• 結果のマージと統合

アーキテクチャ

Input Task
    ↓
[Dispatcher]
    ↓
├─ Worker 1 → Task A
├─ Worker 2 → Task B
├─ Worker 3 → Task C
    ↓
[Result Merger]
    ↓
Unified Output

実装

1. タスク定義

tasks = [
    Task(id=1, work="process data A"),
    Task(id=2, work="process data B"),
    Task(id=3, work="process data C"),
]

2. Dispatch

dispatcher.run_parallel(tasks, workers=3)

3. Results

results = dispatcher.get_results()
merged = merge_results(results)

ベストプラクティス

• タスク粒度を適切に設定
• エラーハンドリング
• ロギング
• モニタリング
• タイムアウト管理

詳細については、ドキュメントを参照してください。