WIP almost done with track planning
This commit is contained in:
9
conductor/tracks/pipeline_pause_resume_20260306/index.md
Normal file
9
conductor/tracks/pipeline_pause_resume_20260306/index.md
Normal file
@@ -0,0 +1,9 @@
|
||||
# Pipeline Pause/Resume
|
||||
|
||||
**Track ID:** pipeline_pause_resume_20260306
|
||||
|
||||
**Status:** Planned
|
||||
|
||||
**See Also:**
|
||||
- [Spec](./spec.md)
|
||||
- [Plan](./plan.md)
|
||||
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"id": "pipeline_pause_resume_20260306",
|
||||
"name": "Pipeline Pause/Resume",
|
||||
"status": "planned",
|
||||
"created_at": "2026-03-06T00:00:00Z",
|
||||
"updated_at": "2026-03-06T00:00:00Z",
|
||||
"type": "feature",
|
||||
"priority": "medium"
|
||||
}
|
||||
@@ -1,16 +1,32 @@
|
||||
# Implementation Plan: Pipeline Pause/Resume (pipeline_pause_resume)
|
||||
# Implementation Plan: Pipeline Pause/Resume (pipeline_pause_resume_20260306)
|
||||
|
||||
## Phase 1: Research & Design
|
||||
- [ ] Task: Analyze existing backend implementation
|
||||
- [ ] Task: Design GUI/UX approach
|
||||
- [ ] Task: Conductor - User Manual Verification
|
||||
## Phase 1: Pause Mechanism
|
||||
- [ ] Task: Initialize MMA Environment
|
||||
- [ ] Task: Add pause state
|
||||
- WHERE: src/multi_agent_conductor.py
|
||||
- WHAT: Global pause flag
|
||||
- HOW: threading.Event
|
||||
- [ ] Task: Implement pause
|
||||
- WHERE: src/multi_agent_conductor.py
|
||||
- WHAT: Stop worker spawning
|
||||
- HOW: Check pause flag
|
||||
|
||||
## Phase 2: Implementation
|
||||
- [ ] Task: Implement feature
|
||||
- [ ] Task: Write tests
|
||||
- [ ] Task: Conductor - User Manual Verification
|
||||
## Phase 2: Resume Mechanism
|
||||
- [ ] Task: Implement resume
|
||||
- WHERE: src/multi_agent_conductor.py
|
||||
- WHAT: Continue from pause
|
||||
- HOW: Clear flag, restart workers
|
||||
|
||||
## Phase 3: Verification
|
||||
- [ ] Task: Run test suite
|
||||
- [ ] Task: Verify coverage
|
||||
- [ ] Task: Conductor - Phase Completion Verification
|
||||
## Phase 3: UI
|
||||
- [ ] Task: Add pause button
|
||||
- WHERE: src/gui_2.py
|
||||
- WHAT: Toggle pause state
|
||||
- HOW: imgui.button
|
||||
- [ ] Task: Add visual indicator
|
||||
- WHERE: src/gui_2.py
|
||||
- WHAT: Show paused status
|
||||
- HOW: Banner or icon
|
||||
|
||||
## Phase 4: Verification
|
||||
- [ ] Test pause/resume
|
||||
- [ ] Conductor - Phase Verification
|
||||
|
||||
@@ -1,27 +1,21 @@
|
||||
# Track Specification: Pipeline Pause/Resume
|
||||
# Track Specification: Pipeline Pause/Resume (pipeline_pause_resume_20260306)
|
||||
|
||||
## Overview
|
||||
Global pause/resume for entire DAG execution pipeline.
|
||||
Add global pause/resume for entire DAG execution pipeline. Allow user to freeze all worker activity and resume later.
|
||||
|
||||
## Current State Audit
|
||||
### Already Implemented
|
||||
- DAG engine execution
|
||||
- auto_queue mode
|
||||
|
||||
### Gaps to Fill
|
||||
- No pause mechanism
|
||||
- No resume capability
|
||||
|
||||
## Goals
|
||||
- Global pause button
|
||||
- Resume button
|
||||
- Frozen state visualization
|
||||
## Architectural Constraints
|
||||
- **State Preservation**: Worker state MUST be preserved across pause.
|
||||
- **Atomic Operation**: Pause/Resume MUST be atomic.
|
||||
|
||||
## Functional Requirements
|
||||
- Pause all workers
|
||||
- Resume from paused state
|
||||
- State persistence
|
||||
- **Pause Button**: Freeze all worker activity.
|
||||
- **Resume Button**: Continue from paused state.
|
||||
- **Visual Indicator**: Show pipeline is paused.
|
||||
- **State Display**: Show which workers are paused.
|
||||
|
||||
## Non-Functional Requirements
|
||||
- Worker state preservation
|
||||
- Clean resume
|
||||
## Acceptance Criteria
|
||||
- [ ] Pause button freezes pipeline.
|
||||
- [ ] Resume button continues execution.
|
||||
- [ ] Visual indicator shows paused state.
|
||||
- [ ] Worker states preserved.
|
||||
- [ ] No data loss on resume.
|
||||
|
||||
Reference in New Issue
Block a user