dmux-workflows

# dmux ワークフロー 複数のエージェントとタスク集約処理の調整。 ## 使用時期 - 複数のタスクを並行して実行 - 大規模なワークフローを調整 - エージェント間でタスクを分配 - エラーハンドリングとリトライ - 結果のマージと統合 ## アーキテクチャ ``` Input Task ↓ [Dispatcher] ↓ ├─ Worker 1 → Task A ├─ Worker 2 → Task B ├─ Worker 3 → Task C ↓ [Result Merger] ↓ Unified Output ``` ## 実装 ### 1. タスク定義 ```python tasks = [ Task(id=1, work="process data A"), Task(id=2, work="process data B"), Task(id=3, work="process data C"), ] ``` ### 2. Dispatch ```python dispatcher.run_parallel(tasks, workers=3) ``` ### 3. Results ```python results = dispatcher.get_results() merged = merge_results(results) ``` ## ベストプラクティス - [ ] タスク粒度を適切に設定 - [ ] エラーハンドリング - [ ] ロギング - [ ] モニタリング - [ ] タイムアウト管理 詳細については、ドキュメントを参照してください。