Task

Snowflake Documentation

Represents a scheduled task in Snowflake that performs a specified SQL statement at a recurring interval.

Examples

Python

task = Task(
    name="some_task",
    warehouse="some_warehouse",
    schedule="USING CRON 0 9 * * * UTC",
    state="SUSPENDED",
    as_="SELECT 1"
)

YAML

tasks:
  - name: some_task
    warehouse: some_warehouse
    schedule: "USING CRON 0 9 * * * UTC"
    state: SUSPENDED
    as_: |
        SELECT 1

Fields

  • warehouse (string or Warehouse) - The warehouse used by the task.

  • user_task_managed_initial_warehouse_size (string or WarehouseSize) - The initial warehouse size when the task is managed by the user. Defaults to None.

  • schedule (string) - The schedule on which the task runs.

  • config (string) - Configuration settings for the task.

  • allow_overlapping_execution (bool) - Whether the task can have overlapping executions.

  • user_task_timeout_ms (int) - The timeout in milliseconds after which the task is aborted.

  • suspend_task_after_num_failures (int) - The number of consecutive failures after which the task is suspended.

  • error_integration (string) - The integration used for error handling.

  • copy_grants (bool) - Whether to copy grants from the referenced objects.

  • comment (string) - A comment for the task.

  • after (list) - A list of tasks that must be completed before this task runs.

  • when (string) - A conditional expression that determines when the task runs.

  • as_ (string) - The SQL statement that the task executes.

  • state (string or TaskState, required) - The initial state of the task. Defaults to SUSPENDED.

PreviousTagNextUser

Last updated