conductor(plan): mark Phase 1 & 2 complete for mma_multiworker_viz
This commit is contained in:
@@ -5,27 +5,14 @@
|
|||||||
## Phase 1: Stream Structure Enhancement
|
## Phase 1: Stream Structure Enhancement
|
||||||
Focus: Extend existing mma_streams for per-worker tracking
|
Focus: Extend existing mma_streams for per-worker tracking
|
||||||
|
|
||||||
- [ ] Task 1.1: Initialize MMA Environment
|
- [x] Task 1.1: Initialize MMA Environment (skipped - already in context)
|
||||||
- [ ] Task 1.2: Review existing mma_streams structure
|
- [x] Task 1.2: Review existing mma_streams structure - Already exists: Dict[str, str]
|
||||||
- WHERE: `src/app_controller.py` line 142
|
|
||||||
- WHAT: Current is `Dict[str, str]` - stream_id -> accumulated text
|
|
||||||
- NOTE: Keep this structure, add per-worker metadata separately
|
|
||||||
|
|
||||||
## Phase 2: Worker Status Tracking
|
## Phase 2: Worker Status Tracking
|
||||||
Focus: Track worker status separately
|
Focus: Track worker status separately
|
||||||
|
|
||||||
- [ ] Task 2.1: Add worker status dict
|
- [x] Task 2.1: Add worker status dict - Added _worker_status dict to app_controller.py
|
||||||
- WHERE: `src/app_controller.py`
|
- [x] Task 2.2: Update status on worker events - Status updates to "completed" when streaming ends
|
||||||
- WHAT: Track status per worker
|
|
||||||
- HOW:
|
|
||||||
```python
|
|
||||||
self._worker_status: dict[str, str] = {} # stream_id -> "running" | "completed" | "failed" | "killed"
|
|
||||||
```
|
|
||||||
|
|
||||||
- [ ] Task 2.2: Update status on worker events
|
|
||||||
- WHERE: `src/app_controller.py` `_process_pending_gui_tasks()`
|
|
||||||
- WHAT: Update status based on mma events
|
|
||||||
- HOW: On "response" event, set status to "completed"
|
|
||||||
|
|
||||||
## Phase 3: Multi-Pane Display
|
## Phase 3: Multi-Pane Display
|
||||||
Focus: Display all active streams
|
Focus: Display all active streams
|
||||||
|
|||||||
Reference in New Issue
Block a user