de-batch

2026-02-06 09:26:49 +00:00 · 2024-07-29 09:45:06 -04:00 · 2024-07-29 09:45:06 -04:00 · 5de77b6c76
commit 5de77b6c76
parent 90cbbed175
1 changed files with 5 additions and 3 deletions
--- a/macros/snowflake_api/get_blockchain_api.sql
+++ b/macros/snowflake_api/get_blockchain_api.sql
@ -39,7 +39,7 @@ INSERT INTO
              *,
              MOD(ROW_NUMBER() over(
            ORDER BY
-              min_block), 100) rn_mod_out
+              min_block), 1) rn_mod_out
            FROM
              (
                SELECT
@ -92,7 +92,7 @@ INSERT INTO
  ),
  calls AS (
    SELECT
-      groupid_out,
+      min_block,
      ARRAY_AGG(
        { 'jsonrpc': '2.0',
        'id': min_block :: INT,
@ -102,7 +102,9 @@ INSERT INTO
    FROM
      base
    GROUP BY
-      groupid_out
+      min_block
+    LIMIT
+      500
  )
 SELECT
  call,