Snowflake Integration

Poll a user-supplied SQL query on a schedule and emit only NEW rows. Snowflake has no outbound webhooks, so this trigger is polling-based: a Cloudflare cron schedule POSTs the node's webhook URL (a wake-up signal), execute() runs the query, and cursor-column dedup emits only rows not seen on a previous poll. Webhook/schedule provisioning, teardown, and the resolve-payload short-circuit come from ScheduledPollTriggerMixin; the persisted cursor high-water-mark lives in node state (workflow_node_state), NOT config (a headless poll can't write config back).

8 fields

Execute a SQL statement (query / DML / DDL) via the SQL API.

7 fields

Check status / fetch result rows for a previously submitted statement.

2 fields

Abort an in-flight async statement.

1 field

List accessible databases.

3 fields

Create a new database.

2 fields

Describe a single database.

1 field

Drop a named database.

1 field

Create a database from a share.

3 fields

Create a database from a share (deprecated endpoint).

3 fields

Clone an existing database.

5 fields

Create a new, or alter an existing, database.

13 fields

Undrop a database.

1 field

Enable replication for a database.

3 fields

Disable replication for a database.

2 fields

Refresh a secondary database from its primary.

1 field

Enable failover for a database.

2 fields

Disable failover for a database.

2 fields

Promote a secondary database to primary.

1 field

Set a tag on a database.

4 fields

Unset tags from a database.

3 fields

Get the tag assignments for a database.

2 fields

List schemas within a database.

2 fields

List tables in a schema.

3 fields

Describe a single table's metadata / columns.

3 fields

List available compute warehouses.

1 field

Create (or replace) a compute warehouse.

3 fields

Resume a suspended warehouse.

1 field

Suspend a warehouse to stop credit usage.

1 field

Abort all running / queued queries on a warehouse.

1 field

Describe a single warehouse.

1 field

Drop a warehouse.

2 fields

Create a warehouse, or alter it to match if it already exists (full property set required).

19 fields

Rename a warehouse to a new identifier.

3 fields

[Deprecated] Set the active warehouse for the session.

1 field

Enable an adaptive warehouse.

2 fields

Disable an adaptive warehouse.

2 fields

Set a tag on a warehouse.

4 fields

Unset a tag from a warehouse.

3 fields

Get the tag assignments for a warehouse (requires an active warehouse).

2 fields

List scheduled tasks in a schema.

3 fields

Create a scheduled SQL task.

6 fields

Trigger an immediate manual run of a task.

3 fields

Resume (un-suspend) a task.

3 fields

Pause an active task.

3 fields

List completed task graph runs (status / timing).

3 fields

Fetch a single task's definition.

3 fields

Create a task, or alter it to match if it already exists.

24 fields

Drop a task.

4 fields

Fetch the dependent tasks of a task.

4 fields

Get graph runs executing or scheduled for the task (deprecated path).

4 fields

Get graph runs executing or scheduled for the task.

4 fields

Get completed graph runs for the task (deprecated path).

5 fields

Get completed graph runs for the task.

5 fields

Set a tag on an existing task.

6 fields

Unset a tag from an existing task.

5 fields

Get the tag assignments for a task.

4 fields

List Snowflake account users.

1 field

Create a new user account.

3 fields

Drop a named user.

1 field

List account roles.

1 field

List named stages (for file / data loading).

3 fields

Create a stage in a schema.

12 fields

Fetch a single stage's definition.

3 fields

Drop a stage.

4 fields

List files in a stage (equivalent to LIST @stage).

4 fields

Generate a presigned url (and optional encryption materials) for a stage file.

5 fields

List the accessible accounts in the organization.

3 fields

Create an account in the organization.

14 fields

Delete an account.

3 fields

Restore a dropped account that is still within its grace period.

1 field

List alerts in a schema.

6 fields

Create an alert in a schema.

12 fields

Fetch a single alert's definition.

3 fields

Drop an alert.

4 fields

Clone an alert into a (possibly different) schema.

11 fields

Execute an alert immediately.

3 fields

Set a tag on an alert.

6 fields

Unset a tag from an alert.

5 fields

Get the tag assignments for an alert (requires an active warehouse).

4 fields

List API integrations in the account.

1 field

Create an API integration.

16 fields

Fetch a single API integration's definition.

1 field

Create an API integration, or alter it to match if it already exists.

15 fields

Drop an API integration.

2 fields

Set a tag on an API integration.

4 fields

Unset a tag from an API integration.

3 fields

Get the tag assignments for an API integration.

2 fields

List artifact repositories in a schema.

6 fields

Create an artifact repository in a schema.

7 fields

Fetch a single artifact repository's definition.

3 fields

Create an artifact repository, or alter it to match if it already exists.

6 fields

Drop an artifact repository.

4 fields

Rename an artifact repository to a new identifier.

7 fields

List catalog integrations in the account.

1 field

Create a catalog integration.

15 fields

Fetch a single catalog integration's definition.

1 field

Drop a catalog integration.

2 fields

Set a tag on a catalog integration.

4 fields

Unset a tag from a catalog integration.

3 fields

Get the tag assignments for a catalog integration (requires an active warehouse).

2 fields

List compute pools under the account.

3 fields

Create a compute pool.

9 fields

Fetch a single compute pool's definition.

1 field

Create a compute pool, or alter it to match if it already exists.

7 fields

Drop a compute pool.

2 fields

Resume a suspended compute pool.

1 field

Suspend an active compute pool.

1 field

Stop all services on a compute pool (deprecated endpoint).

1 field

Stop all services on a compute pool.

1 field

Set a tag on a compute pool.

4 fields

Unset a tag from a compute pool.

3 fields

Get the tag assignments for a compute pool.

2 fields

List database roles in a database.

3 fields

Create a database role in a database.

4 fields

Drop a database role.

3 fields

Clone a database role into a (possibly different) database.

5 fields

List all grants to a database role.

3 fields

Grant privileges to a database role.

11 fields

Revoke grants from a database role.

12 fields

List all future grants to a database role.

3 fields

Grant future privileges to a database role.

11 fields

Revoke future grants from a database role.

12 fields

Set a tag on a database role.

5 fields

Unset a tag from a database role.

4 fields

Get the tag assignments for a database role (requires an active warehouse).

3 fields

List dynamic tables under a database and schema.

7 fields

Create a dynamic table in a schema.

15 fields

Fetch a single dynamic table's definition.

3 fields

Drop a dynamic table.

4 fields

Clone a dynamic table into a (possibly different) schema.

10 fields

Undrop a previously dropped dynamic table.

3 fields

Suspend refreshes on a dynamic table.

4 fields

Resume refreshes on a dynamic table.

4 fields

Manually refresh a dynamic table.

4 fields

Suspend recluster of a dynamic table.

4 fields

Resume recluster of a dynamic table.

4 fields

Swap a dynamic table with another dynamic table.

7 fields

Set a tag on a dynamic table.

6 fields

Unset a tag from a dynamic table.

5 fields

Get the tag assignments for a dynamic table.

4 fields

List event tables in a schema.

6 fields

Create an event table in a schema.

11 fields

Fetch a single event table's definition.

3 fields

Drop an event table.

4 fields

Rename an event table to a new identifier.

5 fields

Set a tag on an event table.

6 fields

Unset a tag from an event table.

5 fields

Get the tag assignments for an event table (requires an active warehouse).

4 fields

List external volumes in the account.

1 field

Create an external volume.

5 fields

Fetch a single external volume's definition.

1 field

Drop an external volume.

2 fields

Restore the most recently dropped external volume with a given name.

1 field

List user functions in a schema.

3 fields

Create a function in a schema.

9 fields

Fetch a single function's definition.

3 fields

Drop a function.

4 fields

Execute a function.

3 fields

Set tags on a function.

6 fields

Unset tags from a function.

5 fields

Get the tag assignments for a function.

4 fields

Grant the specified privilege(s) on the named securable to the named grantee.

6 fields

Grant privilege(s) on all/future securables of a type in a scope to the named grantee.

8 fields

Revoke the specified privilege on the named securable from the named grantee.

6 fields

Revoke the grant option for the specified privilege on the named securable.

6 fields

Revoke a privilege on all/future securables in the given scope from the named grantee.

8 fields

Revoke the grant option for a privilege on all/future securables in the given scope.

8 fields

List the roles and privileges granted to the specified grantee.

3 fields

List iceberg tables in a schema.

7 fields

Create a Snowflake-managed iceberg table.

19 fields

Create a Snowflake-managed iceberg table from a SELECT query.

10 fields

Create an unmanaged iceberg table from an AWS Glue catalog.

11 fields

Create an unmanaged iceberg table from Delta files.

9 fields

Create an unmanaged iceberg table from Iceberg files.

9 fields

Create an unmanaged iceberg table from an Iceberg REST catalog.

11 fields

Describe a single iceberg table.

3 fields

Drop an iceberg table.

5 fields

Resume reclustering of an iceberg table.

4 fields

Suspend reclustering of an iceberg table.

4 fields

Refresh metadata for an externally-cataloged iceberg table.

5 fields

Convert an unmanaged iceberg table to a Snowflake-managed one.

6 fields

Undrop a previously dropped iceberg table.

3 fields

Clone a Snowflake-managed iceberg table.

8 fields

Create a new iceberg table with the same column definitions as an existing one.

12 fields

Set a tag on an iceberg table.

6 fields

Unset a tag from an iceberg table.

5 fields

Get the tag assignments for an iceberg table.

4 fields

List image repositories in a schema.

3 fields

Create an image repository in a schema.

4 fields

Fetch a single image repository's definition.

3 fields

Drop an image repository.

4 fields

List the images stored in an image repository.

3 fields

Set a tag on an image repository.

6 fields

Unset a tag from an image repository.

5 fields

Get the tag assignments for an image repository.

4 fields

List the accessible managed accounts.

1 field

Create a managed account (reader account).

5 fields

Delete a managed account, including all objects created in it.

1 field

Create a network policy.

7 fields

Fetch a single network policy's definition.

1 field

Drop a network policy.

2 fields

Set a tag on a network policy.

4 fields

Unset a tag from a network policy.

3 fields

Get the tag assignments for a network policy.

2 fields

List network rules in a schema.

6 fields

Create a network rule in a schema.

8 fields

Fetch a single network rule's definition.

3 fields

Drop a network rule.

4 fields

List notebooks in a schema.

6 fields

Create a notebook in a schema.

16 fields

Fetch a single notebook's definition.

3 fields

Drop a notebook.

4 fields

Execute a notebook.

4 fields

Rename a notebook to a new identifier.

7 fields

Add a LIVE version to a notebook.

5 fields

Commit the LIVE version of a notebook to its Git repository.

5 fields

Set a tag on a notebook.

6 fields

Unset a tag from a notebook.

5 fields

Get the tag assignments for a notebook (requires an active warehouse).

4 fields

List notification integrations in the account.

1 field

Create a notification integration.

21 fields

Fetch a single notification integration's definition.

1 field

Drop a notification integration.

2 fields

Set a tag on a notification integration.

4 fields

Unset a tag from a notification integration.

3 fields

Get the tag assignments for a notification integration.

2 fields

List password policies in a schema.

5 fields

Create a password policy in a schema.

16 fields

Fetch a single password policy's definition.

3 fields

Drop a password policy.

4 fields

Rename a password policy to a new identifier.

7 fields

Set a tag on a password policy.

6 fields

Unset a tag from a password policy.

5 fields

Get the tag assignments for a password policy.

4 fields

List pipes in a schema.

3 fields

Create a pipe in a schema.

10 fields

Fetch a single pipe's definition.

3 fields

Drop a pipe.

4 fields

Refresh a pipe to load staged files into the ingest queue.

6 fields

Set a tag on a pipe.

6 fields

Unset a tag from a pipe.

5 fields

Get the tag assignments for a pipe (requires an active warehouse).

4 fields

List procedures in a schema.

3 fields

Create a procedure in a schema.

12 fields

Fetch a single procedure's definition.

3 fields

Drop a procedure.

4 fields

Call a procedure with arguments.

4 fields

Set tags on a procedure.

5 fields

Unset tags from a procedure.

5 fields

Get the tag assignments for a procedure.

4 fields

Create a role.

3 fields

Delete a role.

2 fields

List all grants (privileges/roles) granted to the role.

2 fields

Grant privileges to the role.

10 fields

Revoke grants from the role.

11 fields

List all grants of the role (users/roles it is granted to).

2 fields

List all grants on the role (privileges held on the role securable).

2 fields

List all future grants to the role.

2 fields

Grant future privileges to the role.

10 fields

Revoke future grants from the role.

11 fields

Set tags on a role.

3 fields

Unset tags from a role.

3 fields

Get the tag assignments for a role (requires an active warehouse).

2 fields

Create a schema in a database.

17 fields

Clone an existing schema into a (possibly different) database.

6 fields

Restore a dropped schema.

2 fields

Fetch a single schema's definition.

2 fields

Create a new, or alter an existing, schema.

16 fields

Drop a schema.

4 fields

Set a tag on a schema.

5 fields

Unset tags from a schema.

4 fields

Get the tag assignments for a schema.

3 fields

List secrets in a schema.

6 fields

Create a secret in a schema.

15 fields

Fetch a single secret's definition.

3 fields

Drop a secret.

4 fields

List sequences in a schema.

6 fields

Create a sequence in a schema.

8 fields

Fetch a single sequence's definition.

3 fields

Drop a sequence.

4 fields

Clone a sequence into a (possibly different) schema.

6 fields

Rename a sequence to a new identifier.

7 fields

List services in a schema.

6 fields

Create a service in a schema.

18 fields

Create and execute a job service.

12 fields

Fetch a single service's definition.

3 fields

Create a service, or alter it to match if it already exists.

17 fields

Drop a service.

4 fields

Fetch the logs for a service container instance.

6 fields

Fetch the status for a service (deprecated — prefer List Service Containers).

4 fields

List all containers of a service.

3 fields

List all instances of a service.

3 fields

List all service roles of a service.

3 fields

List all grants of a service role (who the role is granted to).

4 fields

List all grants given to a service role (privileges the role holds).

4 fields

Resume a suspended service.

4 fields

Suspend a running service.

4 fields

List the endpoints exposed by a service.

3 fields

List streams in a schema.

6 fields

Create a stream on a table, external table, view, or stage.

16 fields

Fetch a single stream's definition.

3 fields

Drop a stream.

4 fields

Clone a stream into a (possibly different) schema.

9 fields

Set a tag on a stream.

6 fields

Unset a tag from a stream.

5 fields

Get the tag assignments for a stream (requires an active warehouse).

4 fields

List Streamlits in a schema.

6 fields

Create a Streamlit application, or replace an existing one.

12 fields

Fetch a single Streamlit's details.

3 fields

Delete a Streamlit (restorable via undrop within the retention period).

4 fields

Restore a previously deleted Streamlit within the retention period.

3 fields

Rename a Streamlit, optionally into a different database or schema.

7 fields

Add a live version to a Streamlit, making a version active for users.

6 fields

Commit the LIVE version of a Streamlit to its connected Git repository.

4 fields

Add a new version to a Streamlit by copying files from a stage location.

7 fields

Add a new version to a Streamlit using a Git tag or commit reference URI.

6 fields

Abort the live version of a Streamlit, discarding uncommitted changes.

3 fields

Pull the latest changes from the Git repository for a Streamlit.

3 fields

Push committed changes from a Streamlit back to its Git repository.

11 fields

Set a tag on a Streamlit.

6 fields

Unset a tag from a Streamlit.

5 fields

Get the tag assignments for a Streamlit.

4 fields

Create a table in a schema.

15 fields

Create a table from the result of a SELECT query.

8 fields

(Deprecated) Create a table from a SELECT query (name in the path).

6 fields

Create a table using templates in staged files (INFER_SCHEMA).

6 fields

(Deprecated) Create a table using templates in staged files (name in the path).

6 fields

Create a table, or alter it to match if it already exists.

13 fields

Drop a table.

4 fields

Clone a table into a (possibly different) schema.

9 fields

Create a new empty table like an existing one.

6 fields

(Deprecated) Create a new empty table like an existing one.

6 fields

Undrop a previously dropped table.

3 fields

Suspend automatic reclustering for a table.

4 fields

(Deprecated) Suspend automatic reclustering for a table.

4 fields

Resume automatic reclustering for a table.

4 fields

(Deprecated) Resume automatic reclustering for a table.

4 fields

Swap a table's metadata and data with another table.

7 fields

(Deprecated) Swap a table with another table (fully-qualified target).

5 fields

Set a tag on a table.

6 fields

Unset a tag from a table.

5 fields

Get the tag assignments for a table (requires an active warehouse).

4 fields

List tags in a schema.

3 fields

Create a tag in a schema.

8 fields

Fetch a single tag's definition.

3 fields

Create a tag, or alter it to match if it already exists.

7 fields

Drop a tag.

4 fields

Restore the most recently dropped tag of this name.

3 fields

Rename a tag to a new identifier.

7 fields

Fetch information about a single user (DESCRIBE result).

1 field

Create a user, or alter it to match if it already exists (full property set required).

23 fields

List all grants (roles) granted to the user.

2 fields

Grant a role to the user.

8 fields

Revoke grants (roles) from the user.

8 fields

Set tags on a user.

3 fields

Unset tags from a user.

3 fields

Get the tag assignments for a user (requires an active warehouse).

2 fields

List user-defined functions in a schema.

3 fields

Create a user-defined function in a schema.

14 fields

Fetch a single UDF's definition.

3 fields

Drop a UDF.

4 fields

Execute a UDF with the given arguments.

4 fields

Rename a UDF to a new identifier.

7 fields

Set tags on a UDF.

5 fields

Unset tags from a UDF.

5 fields

Get the tag assignments for a UDF.

4 fields

List views in a schema.

7 fields

Create a view in a schema.

11 fields

Fetch a single view's definition.

3 fields

Drop a view.

4 fields

Set tags on a view.

5 fields

Unset tags from a view.

5 fields

Get the tag assignments for a view (requires an active warehouse).

4 fields