From d09d5612f3f95dd08997ea095384b70b10c8dcb3 Mon Sep 17 00:00:00 2001
From: "opencode-agent[bot]" <opencode-agent[bot]@users.noreply.github.com>
Date: Fri, 10 Jul 2026 00:55:59 +0000
Subject: [PATCH] chore: generate

---
 packages/stats/core/src/athena.ts | 57 ++++++++++++++-----------------
 1 file changed, 26 insertions(+), 31 deletions(-)

diff --git a/packages/stats/core/src/athena.ts b/packages/stats/core/src/athena.ts
index 8879d52a660..96a48d37103 100644
--- a/packages/stats/core/src/athena.ts
+++ b/packages/stats/core/src/athena.ts
@@ -113,37 +113,32 @@ const poll: (
   return yield* poll(client, queryExecutionId, attempt + 1)
 })
 
-const results: (
-  client: AwsAthenaClient,
-  queryExecutionId: string,
-) => Effect.Effect<AthenaData[], AthenaQueryError> = Effect.fn("Athena.results")(function* (
-  client: AwsAthenaClient,
-  queryExecutionId: string,
-) {
-  // Accumulate pages iteratively; recursive spreads copied every previously
-  // fetched row per page and blew up memory on large result sets.
-  const rows: AthenaData[] = []
-  let nextToken: string | undefined
-  while (true) {
-    const result = yield* Effect.tryPromise({
-      try: () =>
-        client.send(
-          new GetQueryResultsCommand({
-            QueryExecutionId: queryExecutionId,
-            NextToken: nextToken,
-            MaxResults: ATHENA_PAGE_SIZE,
-          }),
-        ),
-      catch: (cause) =>
-        new AthenaQueryError({ message: "Failed to read Athena stats results", queryExecutionId, cause }),
-    })
-    const columns = result.ResultSet?.ResultSetMetadata?.ColumnInfo?.map((item) => item.Name ?? "") ?? []
-    // The first page starts with the header row.
-    for (const row of (result.ResultSet?.Rows ?? []).slice(nextToken ? 0 : 1)) rows.push(rowData(columns, row))
-    if (!result.NextToken) return rows
-    nextToken = result.NextToken
-  }
-})
+const results: (client: AwsAthenaClient, queryExecutionId: string) => Effect.Effect<AthenaData[], AthenaQueryError> =
+  Effect.fn("Athena.results")(function* (client: AwsAthenaClient, queryExecutionId: string) {
+    // Accumulate pages iteratively; recursive spreads copied every previously
+    // fetched row per page and blew up memory on large result sets.
+    const rows: AthenaData[] = []
+    let nextToken: string | undefined
+    while (true) {
+      const result = yield* Effect.tryPromise({
+        try: () =>
+          client.send(
+            new GetQueryResultsCommand({
+              QueryExecutionId: queryExecutionId,
+              NextToken: nextToken,
+              MaxResults: ATHENA_PAGE_SIZE,
+            }),
+          ),
+        catch: (cause) =>
+          new AthenaQueryError({ message: "Failed to read Athena stats results", queryExecutionId, cause }),
+      })
+      const columns = result.ResultSet?.ResultSetMetadata?.ColumnInfo?.map((item) => item.Name ?? "") ?? []
+      // The first page starts with the header row.
+      for (const row of (result.ResultSet?.Rows ?? []).slice(nextToken ? 0 : 1)) rows.push(rowData(columns, row))
+      if (!result.NextToken) return rows
+      nextToken = result.NextToken
+    }
+  })
 
 function rowData(columns: string[], row: Row): AthenaData {
   return Object.fromEntries(