diff --git a/conductor/tracks/update_monitor_discovery_20260208/plan.md b/conductor/tracks/update_monitor_discovery_20260208/plan.md index 318bb2a..f159f35 100644 --- a/conductor/tracks/update_monitor_discovery_20260208/plan.md +++ b/conductor/tracks/update_monitor_discovery_20260208/plan.md @@ -6,13 +6,13 @@ - [x] Implement `get_job_allocations(job_id)` returning a list of dicts (id, node, ip) - [x] Task: Conductor - User Manual Verification 'Phase 1: Nomad Discovery Enhancement' (Protocol in workflow.md) -## Phase 2: Aggregator Refactor [ ] -- [ ] Task: Refactor `cluster_aggregator.py` to drive discovery via Nomad - - [ ] Update `get_cluster_status` to call `nomad_client.get_job_allocations` first - - [ ] Update loop to iterate over allocations and supplement with LiteFS and Consul data -- [ ] Task: Update `consul_client.py` to fetch all services once and allow lookup by IP/ID -- [ ] Task: Update tests for the new discovery flow -- [ ] Task: Conductor - User Manual Verification 'Phase 2: Aggregator Refactor' (Protocol in workflow.md) +## Phase 2: Aggregator Refactor [x] [checkpoint: 655a9b2] +- [x] Task: Refactor `cluster_aggregator.py` to drive discovery via Nomad (655a9b2) + - [x] Update `get_cluster_status` to call `nomad_client.get_job_allocations` first + - [x] Update loop to iterate over allocations and supplement with LiteFS and Consul data +- [x] Task: Update `consul_client.py` to fetch all services once and allow lookup by IP/ID (655a9b2) +- [x] Task: Update tests for the new discovery flow (655a9b2) +- [x] Task: Conductor - User Manual Verification 'Phase 2: Aggregator Refactor' (Protocol in workflow.md) ## Phase 3: UI and Health Logic [ ] - [ ] Task: Update `output_formatter.py` for "Standby" nodes