chore: apply oxfmt formatting

Author: ericallam

apps/webapp/app/presenters/v3/BuiltInDashboards.server.ts

@@ -635,7 +635,11 @@ const queuesDashboard: BuiltInDashboard = {
       pressure: {
         title: "Queue pressure",
         query: `SELECT queue,\n  argMax(max_running, bucket_start) AS running,\n  argMax(max_queued, bucket_start) AS queued,\n  argMax(max_limit, bucket_start) AS limit,\n  running + queued AS demand,\n  max(max_queued) AS peak_queued,\n  sum(throttled_count) AS throttled,\n  multiIf(running >= limit AND queued > 0, 'queue-limited', queued > 0, 'backlogged', 'healthy') AS status\nFROM queue_metrics\nGROUP BY queue\nORDER BY peak_queued DESC`,
-        display: { type: "table", prettyFormatting: true, sorting: [{ id: "peak_queued", desc: true }] },
+        display: {
+          type: "table",
+          prettyFormatting: true,
+          sorting: [{ id: "peak_queued", desc: true }],
+        },
       },
       "t-trends": { title: "Per-queue trends", query: "", display: { type: "title" } },
       "running-q": {

apps/webapp/app/presenters/v3/QueueMetricsPresenter.server.ts

@@ -58,7 +58,8 @@ export class QueueMetricsPresenter {
     const bucketSeconds = Math.max(60, Math.round(windowSeconds / SPARKLINE_POINTS));
     const numBuckets = Math.ceil(windowSeconds / bucketSeconds);
     const nowSeconds = Math.floor(Date.now() / 1000);
-    const gridStartSeconds = Math.floor((nowSeconds - windowSeconds) / bucketSeconds) * bucketSeconds;
+    const gridStartSeconds =
+      Math.floor((nowSeconds - windowSeconds) / bucketSeconds) * bucketSeconds;
     const bucketStartMs = gridStartSeconds * 1000;
     const bucketIntervalMs = bucketSeconds * 1000;
 
@@ -144,5 +145,4 @@ export class QueueMetricsPresenter {
       return empty;
     }
   }
-
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.dashboards.$dashboardKey/route.tsx

@@ -53,7 +53,10 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
 
   // The built-in "queues" dashboard is part of the metrics UI (unlinked, but reachable by
   // URL), so gate it per-org like the rest of the Queue Metrics view.
-  if (dashboardKey === "queues" && !(await canAccessQueueMetricsUi({ userId: user.id, organizationSlug }))) {
+  if (
+    dashboardKey === "queues" &&
+    !(await canAccessQueueMetricsUi({ userId: user.id, organizationSlug }))
+  ) {
     throw new Response(undefined, { status: 404, statusText: "Not found" });
   }
 

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.queues/route.tsx

@@ -109,9 +109,11 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const { organizationSlug, projectParam, envParam } = EnvironmentParamSchema.parse(params);
 
   const url = new URL(request.url);
-  const { page, query, period: rawPeriod } = SearchParamsSchema.parse(
-    Object.fromEntries(url.searchParams)
-  );
+  const {
+    page,
+    query,
+    period: rawPeriod,
+  } = SearchParamsSchema.parse(Object.fromEntries(url.searchParams));
   const period: QueueMetricsWindow = isQueueMetricsWindow(rawPeriod) ? rawPeriod : "24h";
 
   const project = await findProjectBySlug(organizationSlug, projectParam, userId);
@@ -153,7 +155,10 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
       window: QueueMetricsWindow;
       bucketStartMs: number;
       bucketIntervalMs: number;
-      byQueue: Record<string, import("~/presenters/v3/QueueMetricsPresenter.server").QueueListMetric>;
+      byQueue: Record<
+        string,
+        import("~/presenters/v3/QueueMetricsPresenter.server").QueueListMetric
+      >;
     } | null = null;
 
     if (queueMetricsUiEnabled && queues.success) {
@@ -404,8 +409,7 @@ function QueuesWithMetricsView() {
               </LinkButton>
             )
           ) : null}
-          {environment.runsEnabled &&
-          env.pauseSource !== ENVIRONMENT_PAUSE_SOURCE_BILLING_LIMIT ? (
+          {environment.runsEnabled && env.pauseSource !== ENVIRONMENT_PAUSE_SOURCE_BILLING_LIMIT ? (
             <EnvironmentPauseResumeButton env={env} />
           ) : null}
           <LinkButton
@@ -1209,7 +1213,13 @@ const QUEUE_HEADER_TILES: QueueHeaderTile[] = [
   },
 ];
 
-function QueueEnvMetricTile({ tile, period }: { tile: QueueHeaderTile; period: QueueMetricsWindow }) {
+function QueueEnvMetricTile({
+  tile,
+  period,
+}: {
+  tile: QueueHeaderTile;
+  period: QueueMetricsWindow;
+}) {
   const organization = useOrganization();
   const project = useProject();
   const environment = useEnvironment();
@@ -1288,7 +1298,9 @@ function QueueEnvMetricTile({ tile, period }: { tile: QueueHeaderTile; period: Q
       {showLoading ? (
         <div className="h-12 w-full animate-pulse rounded bg-grid-bright/60" />
       ) : failed ? (
-        <div className="flex h-12 items-center text-xs text-text-dimmed">Unable to load metrics</div>
+        <div className="flex h-12 items-center text-xs text-text-dimmed">
+          Unable to load metrics
+        </div>
       ) : (
         <MiniChart data={sparkline} color={tile.color} />
       )}
@@ -1407,7 +1419,6 @@ function formatWaitMs(ms: number): string {
   return `${(ms / 3_600_000).toFixed(1)}h`;
 }
 
-
 // Classic Queues page, restored verbatim from before the Queue Metrics feature. Rendered
 // when queueMetricsUiEnabled is off so a gated org sees exactly the pre-metrics UI.
 function ClassicQueuesView() {

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.queues_.$queueParam/route.tsx

@@ -55,7 +55,8 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   if (!project) throw new Response(undefined, { status: 404, statusText: "Project not found" });
 
   const environment = await findEnvironmentBySlug(project.id, envParam, userId);
-  if (!environment) throw new Response(undefined, { status: 404, statusText: "Environment not found" });
+  if (!environment)
+    throw new Response(undefined, { status: 404, statusText: "Environment not found" });
 
   const retrieve = await new QueueRetrievePresenter().call({ environment, queueInput: queueParam });
   if (!retrieve.success) {
@@ -330,7 +331,9 @@ function QueueDetailChartCard({
               />
               <Tooltip
                 cursor={{ stroke: "rgba(255,255,255,0.12)" }}
-                content={<QueueChartTooltip series={series} formatX={formatX} valueFormat={valueFormat} />}
+                content={
+                  <QueueChartTooltip series={series} formatX={formatX} valueFormat={valueFormat} />
+                }
                 allowEscapeViewBox={{ x: true, y: true }}
                 wrapperStyle={{ zIndex: 1000 }}
                 animationDuration={0}
@@ -382,7 +385,10 @@ function QueueChartTooltip({
         const value = entry?.value;
         return (
           <div key={s.key} className="flex items-center gap-2 text-xs">
-            <span className="inline-block h-2 w-2 rounded-full" style={{ backgroundColor: s.color }} />
+            <span
+              className="inline-block h-2 w-2 rounded-full"
+              style={{ backgroundColor: s.color }}
+            />
             <span className="text-text-dimmed">{s.label}</span>
             <span className="tabular-nums text-text-bright">
               {value === null || value === undefined
@@ -421,13 +427,21 @@ function QueueStats({
     <div className="grid grid-cols-2 gap-2 sm:grid-cols-4 lg:grid-cols-6">
       <Stat label="Running now" value={queue.running.toLocaleString()} />
       <Stat label="Queued now" value={queue.queued.toLocaleString()} />
-      <Stat label="Limit" value={row ? toNumber(row.lim).toLocaleString() : "–"} loading={showLoading} />
+      <Stat
+        label="Limit"
+        value={row ? toNumber(row.lim).toLocaleString() : "–"}
+        loading={showLoading}
+      />
       <Stat
         label="Peak queued"
         value={row ? toNumber(row.peak_queued).toLocaleString() : "–"}
         loading={showLoading}
       />
-      <Stat label="Started" value={row ? toNumber(row.started).toLocaleString() : "–"} loading={showLoading} />
+      <Stat
+        label="Started"
+        value={row ? toNumber(row.started).toLocaleString() : "–"}
+        loading={showLoading}
+      />
       <Stat
         label="Worst delay p95"
         value={worstP95 > 0 ? formatWaitMs(worstP95) : "–"}

apps/webapp/app/routes/admin.queue-metrics.tsx

@@ -141,9 +141,9 @@ export default function AdminQueueMetricsRoute() {
           </div>
           <Paragraph variant="extra-small">
             Depth = entries buffered in the shard stream; Lag = entries not yet delivered to the
-            consumer group (rising = consumer falling behind; "unknown" = entries were trimmed
-            past the group, i.e. data was lost); Pending = unacked entries. Gauges and counters
-            share one stream family on the metrics Redis.
+            consumer group (rising = consumer falling behind; "unknown" = entries were trimmed past
+            the group, i.e. data was lost); Pending = unacked entries. Gauges and counters share one
+            stream family on the metrics Redis.
           </Paragraph>
           {lagUnknownCount > 0 && (
             <Callout variant="error">

apps/webapp/app/v3/querySchemas.ts

@@ -722,35 +722,60 @@ export const queueMetricsSchema: TableSchema = {
     },
     max_queued: {
       name: "max_queued",
-      ...column("UInt32", { description: "Peak queue depth in the bucket. Aggregate with max().", coreColumn: true, fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "Peak queue depth in the bucket. Aggregate with max().",
+        coreColumn: true,
+        fillMode: "carry",
+      }),
     },
     max_running: {
       name: "max_running",
-      ...column("UInt32", { description: "Peak running (concurrency) in the bucket. Aggregate with max().", coreColumn: true, fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "Peak running (concurrency) in the bucket. Aggregate with max().",
+        coreColumn: true,
+        fillMode: "carry",
+      }),
     },
     max_limit: {
       name: "max_limit",
-      ...column("UInt32", { description: "The queue concurrency limit. Aggregate with max().", coreColumn: true, fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "The queue concurrency limit. Aggregate with max().",
+        coreColumn: true,
+        fillMode: "carry",
+      }),
     },
     max_env_queued: {
       name: "max_env_queued",
-      ...column("UInt32", { description: "Peak environment-wide queued in the bucket. Aggregate with max().", fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "Peak environment-wide queued in the bucket. Aggregate with max().",
+        fillMode: "carry",
+      }),
     },
     max_env_running: {
       name: "max_env_running",
-      ...column("UInt32", { description: "Peak environment-wide running in the bucket. Aggregate with max().", fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "Peak environment-wide running in the bucket. Aggregate with max().",
+        fillMode: "carry",
+      }),
     },
     max_env_limit: {
       name: "max_env_limit",
-      ...column("UInt32", { description: "The environment concurrency limit. Aggregate with max().", fillMode: "carry" }),
+      ...column("UInt32", {
+        description: "The environment concurrency limit. Aggregate with max().",
+        fillMode: "carry",
+      }),
     },
     wait_ms_sum: {
       name: "wait_ms_sum",
-      ...column("UInt64", { description: "Sum of scheduling delays (ms). Mean = wait_ms_sum/wait_ms_count." }),
+      ...column("UInt64", {
+        description: "Sum of scheduling delays (ms). Mean = wait_ms_sum/wait_ms_count.",
+      }),
     },
     wait_ms_count: {
       name: "wait_ms_count",
-      ...column("UInt64", { description: "Count of scheduling-delay samples. Aggregate with sum()." }),
+      ...column("UInt64", {
+        description: "Count of scheduling-delay samples. Aggregate with sum().",
+      }),
     },
     wait_quantiles: {
       name: "wait_quantiles",

apps/webapp/app/v3/queueMetrics.server.ts

@@ -127,11 +127,7 @@ export type LabeledShardState = ShardState & { stream: "queue_metrics" };
 
 export async function probeQueueMetricsStreams(): Promise<LabeledShardState[]> {
   const def = metricsDefinition();
-  const states = await probeShardStates(
-    metricsAdminRedis(),
-    allStreamKeys(def),
-    def.consumerGroup
-  );
+  const states = await probeShardStates(metricsAdminRedis(), allStreamKeys(def), def.consumerGroup);
   return states.map((s) => ({ ...s, stream: "queue_metrics" as const }));
 }