--- path: /studio/aja/distributed-processing surface: studio domain: aja auth: signed-in + studio entitlement source: apps/oshun/web/src/app/studio/aja/distributed-processing/page.tsx status: walked + e2e-covered last_walked: '2026-07-02 pipeline-control lane addendum — Playwright real-dev-infra coverage now proves signed-in render, route-map contract, quick-action href order, ready plan/efficiency forms, 44 px submit targets, client guards with no POST for negative queue depth and fractional worker count, real autoscaler worker plan, real scaling-efficiency result, fail-closed loading/unauthorized/ catalog-error states, mobile no-overflow, and direct BFF 401/403/400/200 gates for plan-workers and efficiency. Spec: apps/oshun/web/e2e/studio-aja-pipeline-control-lane-consoles.spec.ts.' '2026-05-29 automated runtime walk (Playwright headless) — render, /v1 data (2xx), console/page-errors, expected content, screenshot verified; live screen-reader, touch, offline, and telemetry-delivery checks pending a manual AT pass. Evidence: WALKTHROUGH/results/runtime-sweep-2026-05-29.md; body re-derived 2026-06-03 from current source (lane-console architecture)' --- # Aja Distributed Processing ## Purpose Admin lane console wired to the real `@aja/distributed-workers` autoscaler via `/v1/admin/aja/distributed-processing`. Its single "Autoscaler Operations Lane" sizes the worker pool needed to clear a queue by a deadline (queue depth + avg task time + target completion → optimal workers, clamped to policy bounds) and scores scaling efficiency from actual throughput vs. theoretical. ## Entry points - **Direct URL** — `/studio/aja/distributed-processing` (signed-in + studio entitlement) - **Sibling quick-actions from this page** — Batch Operations, Back to Studio ## Layout regions `page.tsx` mounts `ShellLayout` with `active="studio"` and renders three panels. - **Workspace panel** (`data-aja-distributed-processing-workspace`): - `

` "Aja Distributed Processing Workspace" (via `WorkspaceHeading`) - `

` — "Dedicated Distributed Processing route with dense expert-mode controls, progressive disclosure, and canonical route map. The operations lane sizes the worker pool and scores scaling efficiency on the real autoscaler." - `

` "Autoscaler Operations Lane" wrapping the plan + efficiency forms (`data-aja-dp-engine-summary` from the catalog) - **Route Map panel** (`data-aja-distributed-processing-route-map`): `

` "Route Map" + one `
` per `STUDIO_AJA_DISTRIBUTED_PROCESSING_ROUTE_MAP` entry (5 entries) - **Quick actions panel**: `.quickAction` ``s — see Interactions ## States - [x] **Loading** — `data-aja-dp-loading` "Loading autoscaler…" - [x] **Unauthorized** — on 401/403, `data-aja-dp-unauthorized` ("Access restricted." + reason, default "Aja workspace scope required to plan distributed processing.") - [x] **Error** — non-OK / malformed / unreachable → `data-aja-dp-error` - [x] **Ready (forms)** — catalog present: plan form + efficiency form - [x] **Plan result** — `data-aja-dp-plan-result` "optimal workers: N (range min–max)" (with "· clamped to max" when `clampedToMax`) - [x] **Efficiency result** — `data-aja-dp-eff-result` "scaling efficiency: x (n% of theoretical)" - [x] **Validation errors** — `data-aja-dp-plan-error` / `data-aja-dp-eff-error` (e.g. "Provide a non-negative integer queue depth and positive task / deadline times.") ## Interactions ### Plan form (`data-aja-dp-plan-form`) - [x] **Queue depth** — `input data-aja-dp-queue` (number) - [x] **Avg task (ms)** — `input data-aja-dp-taskms` (number) - [x] **Deadline (ms)** — `input data-aja-dp-deadline` (number) - [x] **Size worker pool** — `button data-aja-dp-plan-submit`; posts to `/v1/admin/aja/distributed-processing/plan-workers` with queue depth, average task duration, and target completion fields ### Efficiency form (`data-aja-dp-eff-form`) - [x] **Actual throughput (/min)** — `input data-aja-dp-throughput` - [x] **Worker count** — `input data-aja-dp-workers` - [x] **Avg task (ms)** — `input data-aja-dp-eff-taskms` - [x] **Score efficiency** — `button data-aja-dp-eff-submit`; posts to `/v1/admin/aja/distributed-processing/efficiency` with `{ actualThroughput, workerCount, avgTaskDurationMs }` ### Route Map panel (`data-aja-distributed-processing-route-map`) Non-interactive `
` blocks from `STUDIO_AJA_DISTRIBUTED_PROCESSING_ROUTE_MAP` (5 entries): `/studio/aja/distributed-processing` plus `…/scenes/[sceneId]`, `…/exports/[exportId]`, `…/revisions/[revisionId]`, `…/governance/[policyId]`. ### Quick actions panel - [x] **Open Aja Batch Operations workspace** → `/studio/aja/batch-operations` - [x] **Back to Studio workspace index** → `/studio` ## E2E coverage - [`apps/oshun/web/e2e/studio-aja-pipeline-control-lane-consoles.spec.ts`](../../../../apps/oshun/web/e2e/studio-aja-pipeline-control-lane-consoles.spec.ts) covers signed-in shell render, ready plan and efficiency forms, client guards with no `POST` for negative queue depth and fractional worker count, real BFF worker-plan output (`optimal workers: 10`, range `1–10`, clamped to max), real scaling-efficiency output (`0.25` / `25% of theoretical`), route-map count, exact quick-action hrefs, 44 px submit targets, loading / unauthorized / malformed-catalog fail-closed states, mobile no-overflow, and direct BFF auth/schema/happy-path gates. ## Data & contracts - **Reads**: `GET /v1/admin/aja/distributed-processing` (catalog: `summary`, `defaultPolicy`) on mount via `buildBffAuthHeaders()`, `cache: 'no-store'` - **Writes**: `POST …/plan-workers` → `{ result: WorkerPlan }`; `POST …/efficiency` → `{ result: { efficiency } }` - **Realtime**: none - **Caching**: client fetch on mount (no-store); SSR shell only - **Auth**: BFF endpoints admin-scoped + fail-closed (401/403 → unauthorized render); the route is signed-in + studio (proxy gate) ## Cross-references - Parent: [`../../studio-overview.md`](../../studio-overview.md) - Component sources: - `apps/oshun/web/src/components/studio/StudioAjaDistributedProcessingWorkspace.tsx` - `apps/oshun/web/src/components/studio/StudioAjaDistributedProcessingRouteMap.ts` - Embedded by aggregator: `apps/oshun/web/src/components/studio/StudioAjaMotionProcessingWorkspace.tsx` (Distributed Processing Lane) - Sibling from quick-actions: `/studio/aja/batch-operations` ## Known downstream boundaries - Route-map sub-routes (`scenes`/`exports`/`revisions`/`governance`) are descriptive contracts; implementation status of those child pages is tracked separately from this leaf console. - The route remains governed by the shared signed-in + studio entitlement proxy gate for `/studio/aja/*`.