diff --git a/conductor/tracks/mma_multiworker_viz_20260306/plan.md b/conductor/tracks/mma_multiworker_viz_20260306/plan.md index cf9fb75..d2586ac 100644 --- a/conductor/tracks/mma_multiworker_viz_20260306/plan.md +++ b/conductor/tracks/mma_multiworker_viz_20260306/plan.md @@ -22,17 +22,8 @@ Focus: Display all active streams ## Phase 4: Stream Pruning Focus: Limit memory per stream -- [ ] Task 4.1: Prune stream on append - - WHERE: `src/app_controller.py` stream append logic - - WHAT: Limit to 10KB per stream - - HOW: - ```python - MAX_STREAM_SIZE = 10 * 1024 - self.mma_streams[stream_id] += text - if len(self.mma_streams[stream_id]) > MAX_STREAM_SIZE: - self.mma_streams[stream_id] = self.mma_streams[stream_id][-MAX_STREAM_SIZE:] - ``` +- [x] Task 4.1: Prune stream on append - MAX_STREAM_SIZE = 10KB, prunes oldest when exceeded ## Phase 5: Testing -- [ ] Task 5.1: Write unit tests +- [x] Task 5.1: Write unit tests - Tests pass (hooks, api_hook_client, mma_dashboard_streams) - [ ] Task 5.2: Conductor - Phase Verification