feat: overhaul progress tracking, error handling, and CLI display

apps/dashboard/src/pages/PipelineDetail.tsx

@@ -13,15 +13,14 @@ interface StreamProgress {
   status: string
   cumulative_record_count: number
   run_record_count: number
-  records_per_second?: number
   errors?: Array<{ message: string; failure_type?: string }>
 }
 
 interface GlobalProgress {
   elapsed_ms: number
   run_record_count: number
-  rows_per_second: number
-  window_rows_per_second: number
+  records_per_second: number
+  window_records_per_second: number
   state_checkpoint_count: number
 }
 
@@ -201,11 +200,11 @@ export function PipelineDetail({ id, onBack }: PipelineDetailProps) {
           <StatCard label="Total rows" value={formatNumber(globalProgress.run_record_count)} />
           <StatCard
             label="Throughput"
-            value={`${formatNumber(Math.round(globalProgress.rows_per_second))}/s`}
+            value={`${formatNumber(Math.round(globalProgress.records_per_second))}/s`}
           />
           <StatCard
             label="Instantaneous"
-            value={`${formatNumber(Math.round(globalProgress.window_rows_per_second))}/s`}
+            value={`${formatNumber(Math.round(globalProgress.window_records_per_second))}/s`}
           />
           <StatCard label="Elapsed" value={formatDuration(globalProgress.elapsed_ms)} />
         </div>

apps/engine/package.json

@@ -56,17 +56,20 @@
     "dotenv": "^16.4.7",
     "googleapis": "^148.0.0",
     "hono": "^4",
+    "ink": "^7.0.0",
     "openapi-fetch": "^0.17.0",
     "pg": "^8.16.3",
     "pino": "^10",
     "pino-pretty": "^13",
+    "react": "^19.2.4",
     "ws": "^8.18.0",
     "zod": "^4.3.6"
   },
   "devDependencies": {
     "@hyperjump/json-schema": "^1.17.5",
     "@types/node": "^24.10.1",
     "@types/pg": "^8.15.4",
+    "@types/react": "^19.2.14",
     "openapi-typescript": "^7.13.0",
     "vitest": "^3.2.4"
   },