Function deliver

apps/sim/lib/data-drains/destinations/snowflake.ts:469–511

({ body, metadata, signal })

    }
    return {
      async deliver({ body, metadata, signal }) {
        /**
         * Bind the original line bytes — not `JSON.stringify(JSON.parse(line))` —
         * so JSON numbers outside the JS safe-integer range (e.g. Snowflake
         * NUMBER columns past 2^53-1) survive into VARIANT intact. We still
         * parse each line so a malformed payload fails fast at the runner.
         */
        const text = body.toString('utf8')
        const rows: string[] = []
        const lines = text.split(/\r?\n/)
        for (let i = 0; i < lines.length; i++) {
          const line = lines[i]
          if (line.length === 0) continue
          try {
            JSON.parse(line)
          } catch (error) {
            throw new Error(
              `Snowflake NDJSON parse failed at line ${i + 1}: ${toError(error).message}`
            )
          }
          rows.push(line)
        }
        if (rows.length === 0) {
          return {
            locator: `snowflake://${config.account}/${config.database}.${config.schema}.${config.table}#${metadata.runId}-${metadata.sequence}`,
          }
        }
        await executeStatement({
          config,
          getJwt,
          statement: buildStatement(config, rows.length),
          bindings: rows,
          signal,
        })
        logger.debug('Snowflake chunk delivered', {
          account: config.account,
          table: `${config.database}.${config.schema}.${config.table}`,
          rows: rows.length,
        })
        return {
          locator: `snowflake://${config.account}/${config.database}.${config.schema}.${config.table}#${metadata.runId}-${metadata.sequence}`,
        }
      },
      async close() {},
    }
  },