| 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)
ベストプラクティス
詳細については、ドキュメントを参照してください。