fix(snowflake): emit task history time bounds as literals

TASK_HISTORY only accepts bind variables for RESULT_LIMIT and TASK_NAME per
BCR-1410, and that change explicitly excludes a bind passed through another
function first. A bind in SCHEDULED_TIME_RANGE_START/END is therefore dropped
without an error, so the requested window became a no-op and the function fell
back to returning the most recent runs. Emit validated literals instead, which
also restores Snowflake's seven-day range error.

Also reject a fractional skip-file percentage at the block boundary rather than
in the builder, and correct the cancel description: a cancelled child marks the
task graph run failed, so downstream tasks are skipped rather than continuing.

Author: waleedlatif1

apps/docs/content/docs/en/integrations/snowflake.mdx

@@ -785,7 +785,7 @@ Find one task history record by query ID within Snowflake’s seven-day window a
 
 ### Snowflake Cancel Task Query
 
-Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Other tasks in the same task graph keep running and must be cancelled separately.
+Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Task runs already in flight are unaffected and must be cancelled individually; a cancelled child marks the task graph run failed, so downstream tasks are skipped.
 
 #### Input
 

apps/sim/blocks/blocks/snowflake.ts

@@ -70,8 +70,8 @@ function resolveCopyOnError(value: unknown, threshold: unknown): string | undefi
   if (number === undefined || number <= 0) {
     throw new Error('Skip file threshold must be greater than zero')
   }
-  if (value === 'SKIP_FILE_PERCENT' && number > 100) {
-    throw new Error('Skip file percentage must be between 1 and 100')
+  if (value === 'SKIP_FILE_PERCENT' && (number > 100 || !Number.isInteger(number))) {
+    throw new Error('Skip file percentage must be a whole number between 1 and 100')
   }
   if (value === 'SKIP_FILE_NUMBER' && !Number.isInteger(number)) {
     throw new Error('Skip file error count must be a positive integer')

apps/sim/lib/integrations/integrations.json

@@ -18322,7 +18322,7 @@
         },
         {
           "name": "Cancel Task Query",
-          "description": "Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Other tasks in the same task graph keep running and must be cancelled separately."
+          "description": "Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Task runs already in flight are unaffected and must be cancelled individually; a cancelled child marks the task graph run failed, so downstream tasks are skipped."
         },
         {
           "name": "Get Task Run Output",

apps/sim/tools/generated/tool-metadata.ts

@@ -19,7 +19,7 @@ export const cancelTaskRunTool: ToolConfig<
   version: '1.0.0',
   name: 'Snowflake Cancel Task Query',
   description:
-    'Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Other tasks in the same task graph keep running and must be cancelled separately.',
+    'Cancel one running task query by query ID with SYSTEM$CANCEL_QUERY. Task runs already in flight are unaffected and must be cancelled individually; a cancelled child marks the task graph run failed, so downstream tasks are skipped.',
   params: {
     host: {
       type: 'string',

apps/sim/tools/snowflake/cancel_task_run.ts

@@ -422,27 +422,46 @@ describe('Snowflake SQL builders', () => {
       limit: 50,
     })
     expect(history.statement).toContain('RESULT_LIMIT => 50, ERROR_ONLY => TRUE')
-    expect(history.bindings).toEqual({
-      '1': { type: 'TEXT', value: 'DAILY_LOAD' },
-      '2': { type: 'TEXT', value: '2026-08-01T00:00:00Z' },
-    })
+    expect(history.bindings).toEqual({ '1': { type: 'TEXT', value: 'DAILY_LOAD' } })
     const run = buildGetTaskRun({
       ...context,
       queryId,
       taskName: 'DAILY_LOAD',
       startTime: '2026-08-01T00:00:00Z',
     })
     expect(run.statement).toContain('TASK_NAME => ?')
-    expect(run.statement).toContain('SCHEDULED_TIME_RANGE_START => TO_TIMESTAMP_LTZ(?)')
     expect(run.statement).toContain('WHERE QUERY_ID = ?')
     expect(run.bindings).toEqual({
       '1': { type: 'TEXT', value: 'DAILY_LOAD' },
-      '2': { type: 'TEXT', value: '2026-08-01T00:00:00Z' },
-      '3': { type: 'TEXT', value: queryId },
+      '2': { type: 'TEXT', value: queryId },
     })
     expect(() =>
       buildListTaskRuns({ ...context, taskName: 'ANALYTICS.PUBLIC.DAILY_LOAD' })
     ).toThrow('unqualified task name')
+
+    /**
+     * TASK_HISTORY silently drops a bind in its time-range arguments, so the window has to
+     * reach Snowflake as a literal or the filter becomes a no-op with no error.
+     */
+    const window = buildListTaskRuns({
+      ...context,
+      startTime: '2026-08-01T00:00:00Z',
+      endTime: '2026-08-02T00:00:00Z',
+    })
+    expect(window.statement).toContain(
+      "SCHEDULED_TIME_RANGE_START => TO_TIMESTAMP_LTZ('2026-08-01T00:00:00Z')"
+    )
+    expect(window.statement).toContain(
+      "SCHEDULED_TIME_RANGE_END => TO_TIMESTAMP_LTZ('2026-08-02T00:00:00Z')"
+    )
+    expect(window.statement).not.toContain('TO_TIMESTAMP_LTZ(?)')
+    expect(window.bindings).toEqual({})
+    expect(() => buildListTaskRuns({ ...context, startTime: 'not-a-timestamp' })).toThrow(
+      'startTime must be an ISO-8601 timestamp'
+    )
+    expect(() => buildGetTaskRun({ ...context, queryId, endTime: 'nope' })).toThrow(
+      'endTime must be an ISO-8601 timestamp'
+    )
     expect(() =>
       buildGetTaskRun({ ...context, queryId, taskName: 'ANALYTICS.PUBLIC.DAILY_LOAD' })
     ).toThrow('unqualified task name')

apps/sim/tools/snowflake/sql.test.ts

@@ -533,6 +533,20 @@ export function buildRunTask(params: SnowflakeRunTaskParams): SnowflakeStatement
  * yields an empty result set rather than an error. The name is also resolved the way Snowflake
  * stored it, so an unquoted name is upper-cased and a quoted one keeps its exact spelling.
  */
+/**
+ * TASK_HISTORY time-range arguments are `constant_expr` and are not in BCR-1410's bind
+ * allowlist for this function, which covers only RESULT_LIMIT and TASK_NAME. A bind here
+ * is silently dropped rather than rejected, which would turn the requested window into a
+ * no-op, so the timestamp is emitted as a literal instead.
+ */
+function taskHistoryTimestamp(value: string, field: string): string {
+  const trimmed = value.trim()
+  if (Number.isNaN(Date.parse(trimmed))) {
+    throw new Error(`${field} must be an ISO-8601 timestamp within the last seven days`)
+  }
+  return `TO_TIMESTAMP_LTZ(${stringLiteral(trimmed)})`
+}
+
 function unqualifiedTaskName(value: string): string {
   const trimmed = value.trim()
   if (splitQualifiedIdentifier(trimmed).length > 1) {
@@ -552,11 +566,11 @@ export function buildListTaskRuns(params: SnowflakeListTaskRunsParams): Snowflak
   }
   if (params.startTime?.trim()) {
     args.push(
-      `SCHEDULED_TIME_RANGE_START => TO_TIMESTAMP_LTZ(${binds.add(params.startTime.trim())})`
+      `SCHEDULED_TIME_RANGE_START => ${taskHistoryTimestamp(params.startTime, 'startTime')}`
     )
   }
   if (params.endTime?.trim()) {
-    args.push(`SCHEDULED_TIME_RANGE_END => TO_TIMESTAMP_LTZ(${binds.add(params.endTime.trim())})`)
+    args.push(`SCHEDULED_TIME_RANGE_END => ${taskHistoryTimestamp(params.endTime, 'endTime')}`)
   }
   return {
     statement: `SELECT * FROM TABLE(SNOWFLAKE.INFORMATION_SCHEMA.TASK_HISTORY(${args.join(', ')})) ORDER BY SCHEDULED_TIME DESC`,
@@ -572,11 +586,11 @@ export function buildGetTaskRun(params: SnowflakeGetTaskRunParams): SnowflakeSta
   }
   if (params.startTime?.trim()) {
     args.push(
-      `SCHEDULED_TIME_RANGE_START => TO_TIMESTAMP_LTZ(${binds.add(params.startTime.trim())})`
+      `SCHEDULED_TIME_RANGE_START => ${taskHistoryTimestamp(params.startTime, 'startTime')}`
     )
   }
   if (params.endTime?.trim()) {
-    args.push(`SCHEDULED_TIME_RANGE_END => TO_TIMESTAMP_LTZ(${binds.add(params.endTime.trim())})`)
+    args.push(`SCHEDULED_TIME_RANGE_END => ${taskHistoryTimestamp(params.endTime, 'endTime')}`)
   }
   const queryId = binds.add(requireQueryId(params.queryId))
   return {

apps/sim/tools/snowflake/sql.ts

@@ -69,9 +69,9 @@ interface SnowflakeApiResponse {
   statementHandle?: string
   data?: Array<Array<string | null>>
   /**
-   * The SQL API reference and OpenAPI spec both declare `stats` as a direct
-   * property of the ResultSet object. The `resultSetMetaData` fallback below is
-   * defensive only - no documented response uses it.
+   * The SQL API reference declares `stats` as a direct property of the ResultSet
+   * object, and also describes it under `resultSetMetaData`. Snowflake's own docs
+   * are inconsistent here, so both shapes are read with the top-level one winning.
    */
   stats?: SnowflakeApiStats
   resultSetMetaData?: {