conductor(plan): Mark Phase 1 & 2 tasks complete in native_orchestrator

This commit is contained in:
2026-03-07 01:33:04 -05:00
parent 1323d10ea0
commit 78d496d33f

View File

@@ -5,67 +5,21 @@
## Phase 1: Plan File Operations
Focus: Native plan.md read/write
- [ ] Task 1.1: Initialize MMA Environment
- [ ] Task 1.2: Implement read_plan function
- WHERE: `src/orchestrator_pm.py` or new `src/native_orchestrator.py`
- [x] Task 1.1: Initialize MMA Environment (skipped - already in context)
- [x] Task 1.2: Implement read_plan function - COMMITTED: 1323d10
- WHERE: `src/native_orchestrator.py`
- WHAT: Parse plan.md content
- HOW:
```python
def read_plan(track_id: str, base_dir: str = ".") -> str:
plan_path = Path(base_dir) / "conductor" / "tracks" / track_id / "plan.md"
if not plan_path.exists():
return ""
return plan_path.read_text(encoding="utf-8")
```
- [ ] Task 1.3: Implement write_plan function
- WHERE: Same as above
- WHAT: Write plan.md content
- HOW:
```python
def write_plan(track_id: str, content: str, base_dir: str = ".") -> None:
plan_path = Path(base_dir) / "conductor" / "tracks" / track_id / "plan.md"
plan_path.parent.mkdir(parents=True, exist_ok=True)
plan_path.write_text(content, encoding="utf-8")
```
- [x] Task 1.3: Implement write_plan function - COMMITTED: 1323d10
- [ ] Task 1.4: Parse task checkboxes
- WHERE: Same as above
- WHAT: Extract task status from plan
- HOW:
```python
def parse_plan_tasks(content: str) -> list[dict]:
tasks = []
for line in content.split("\n"):
if line.strip().startswith("- ["):
checked = "[x]" in line
tasks.append({"text": line, "completed": checked})
return tasks
```
- [x] Task 1.4: Parse task checkboxes - COMMITTED: 1323d10
## Phase 2: Metadata Operations
Focus: Native metadata.json management
- [ ] Task 2.1: Implement read_metadata
- WHERE: Same as above
- HOW:
```python
def read_metadata(track_id: str, base_dir: str = ".") -> dict:
meta_path = Path(base_dir) / "conductor" / "tracks" / track_id / "metadata.json"
if not meta_path.exists():
return {}
return json.loads(meta_path.read_text(encoding="utf-8"))
```
- [x] Task 2.1: Implement read_metadata - COMMITTED: 1323d10
- [ ] Task 2.2: Implement write_metadata
- WHERE: Same as above
- HOW:
```python
def write_metadata(track_id: str, data: dict, base_dir: str = ".") -> None:
meta_path = Path(base_dir) / "conductor" / "tracks" / track_id / "metadata.json"
meta_path.parent.mkdir(parents=True, exist_ok=True)
meta_path.write_text(json.dumps(data, indent=2), encoding="utf-8")
```
- [x] Task 2.2: Implement write_metadata - COMMITTED: 1323d10
## Phase 3: In-Process Tier Delegation
Focus: Replace subprocess calls with direct function calls