Snowflake

@mfbaig35r/snowflakev2026.06.01.1· 2d agoMODELS

01README

Snowflake warehouses, databases, schemas, stages, tasks, pipes, secrets, and grants as Swamp models. Compose Snowflake pipelines with non-Snowflake resources in Swamp workflows. Backed by the Snowflake SQL Statement Execution API (v2).

02Release Notes

v0.2 (2026.06.01.1) - database + schema models

Two new models in the @mfbaig35r/snowflake pack:

@mfbaig35r/snowflake/database: create, read, update, delete, list, adopt, create_or_update. Supports TRANSIENT databases, DATA_RETENTION_TIME_IN_DAYS, MAX_DATA_EXTENSION_TIME_IN_DAYS, DEFAULT_DDL_COLLATION. delete defaults to RESTRICT (Snowflake's default); pass cascade=true to wipe contained schemas.
@mfbaig35r/snowflake/schema: same method set, scoped to a parent database. Swamp resources keyed by '.' so the same schema name across databases does not collide. Supports WITH MANAGED ACCESS at create and ENABLE/DISABLE MANAGED ACCESS on update.

warehouse model version bumped to 2026.06.01.1 alongside.

Total models: 3.

03Models3

@mfbaig35r/snowflake/warehousev2026.06.01.1warehouse.ts

fn create(name: string, warehouse_type: enum, auto_suspend_seconds?: number, auto_resume: boolean, min_cluster_count: number, max_cluster_count: number, scaling_policy: enum, initially_suspended: boolean, comment?: string)

Create a warehouse via CREATE WAREHOUSE. Defaults to

Argument	Type	Required	Description
name	string	yes
warehouse_type	enum	yes
auto_suspend_seconds?	number	no	Seconds idle before auto-suspend. null disables auto-suspend.
auto_resume	boolean	yes
min_cluster_count	number	yes
max_cluster_count	number	yes
scaling_policy	enum	yes
initially_suspended	boolean	yes	If true (default), the warehouse is created in SUSPENDED state so
comment?	string	no

fn read(warehouse_ref: string)

Fetch live warehouse state via SHOW WAREHOUSES LIKE '<name>'.

Argument	Type	Required	Description
warehouse_ref	string	yes

fn list()

List all warehouses on the account via SHOW WAREHOUSES. Returns the

fn adopt(name: string)

Argument	Type	Required	Description
name	string	yes

fn update(warehouse_ref: string)

Update warehouse settings via ALTER WAREHOUSE <name> SET ... .

Argument	Type	Required	Description
warehouse_ref	string	yes

fn delete(warehouse_ref: string)

Drop the warehouse via DROP WAREHOUSE IF EXISTS <name>.

Argument	Type	Required	Description
warehouse_ref	string	yes

fn resume(warehouse_ref: string)

Resume the warehouse via ALTER WAREHOUSE <name> RESUME IF SUSPENDED.

Argument	Type	Required	Description
warehouse_ref	string	yes

fn suspend(warehouse_ref: string)

Suspend the warehouse via ALTER WAREHOUSE <name> SUSPEND.

Argument	Type	Required	Description
warehouse_ref	string	yes

fn run_query(warehouse_ref: string, statement: string, database?: string, schema?: string, role?: string, server_timeout_seconds: number, async_exec: boolean)

Submit a SQL statement via POST /api/v2/statements bound to this

Argument	Type	Required	Description
warehouse_ref	string	yes
statement	string	yes
database?	string	no
schema?	string	no
role?	string	no
server_timeout_seconds	number	yes	Server-side execution timeout. Snowflake caps at 172800s (48h).
async_exec	boolean	yes	true = return immediately with statement_handle (state RUNNING); poll

fn wait_statement(statement_handle: string, poll_seconds: number, timeout_seconds: number)

Poll GET /api/v2/statements/{handle} until the statement reaches a

Argument	Type	Required
statement_handle	string	yes
poll_seconds	number	yes
timeout_seconds	number	yes

fn cancel_statement(statement_handle: string)

Cancel a running statement via POST /api/v2/statements/{handle}/cancel.

Argument	Type	Required	Description
statement_handle	string	yes

fn create_or_update(name: string, warehouse_type: enum, auto_suspend_seconds?: number, auto_resume: boolean, min_cluster_count: number, max_cluster_count: number, scaling_policy: enum, initially_suspended: boolean, comment?: string)

Reconcile via account state + Swamp data: SHOW WAREHOUSES for the

Argument	Type	Required	Description
name	string	yes
warehouse_type	enum	yes
auto_suspend_seconds?	number	no	Seconds idle before auto-suspend. null disables auto-suspend.
auto_resume	boolean	yes
min_cluster_count	number	yes
max_cluster_count	number	yes
scaling_policy	enum	yes
initially_suspended	boolean	yes	If true (default), the warehouse is created in SUSPENDED state so
comment?	string	no

Resources

warehouse(infinite)— A Snowflake virtual warehouse, keyed by user-supplied name. State

last_statement(workflow)— Most recent statement submitted through this model. sql_preview is

@mfbaig35r/snowflake/databasev2026.06.01.1database.ts

fn create(name: string, transient: boolean, data_retention_time_in_days: number, max_data_extension_time_in_days?: number, default_ddl_collation?: string, comment?: string)

Create a database via CREATE DATABASE / CREATE TRANSIENT DATABASE.

Argument	Type	Required	Description
name	string	yes
transient	boolean	yes	If true, emits CREATE TRANSIENT DATABASE. Transient databases skip
data_retention_time_in_days	number	yes	Time Travel retention. 0..90 for standard, 0..1 for transient.
max_data_extension_time_in_days?	number	no	Max days Snowflake can extend retention past the configured value
default_ddl_collation?	string	no
comment?	string	no

fn read(database_ref: string)

Fetch live database state via SHOW DATABASES LIKE '<name>'.

Argument	Type	Required	Description
database_ref	string	yes

fn list()

List all databases on the account via SHOW DATABASES. Returns the

fn adopt(name: string)

Argument	Type	Required	Description
name	string	yes

fn update(database_ref: string)

Update database settings via ALTER DATABASE <name> SET ... .

Argument	Type	Required	Description
database_ref	string	yes

fn delete(database_ref: string, cascade: boolean)

Drop the database via DROP DATABASE IF EXISTS <name> [CASCADE].

Argument	Type	Required	Description
database_ref	string	yes
cascade	boolean	yes

fn create_or_update(name: string, transient: boolean, data_retention_time_in_days: number, max_data_extension_time_in_days?: number, default_ddl_collation?: string, comment?: string)

Reconcile via account state: SHOW DATABASES for the name. If the

Argument	Type	Required	Description
name	string	yes
transient	boolean	yes	If true, emits CREATE TRANSIENT DATABASE. Transient databases skip
data_retention_time_in_days	number	yes	Time Travel retention. 0..90 for standard, 0..1 for transient.
max_data_extension_time_in_days?	number	no	Max days Snowflake can extend retention past the configured value
default_ddl_collation?	string	no
comment?	string	no

Resources

database(infinite)— A Snowflake database, keyed by name. State refreshed on read.

@mfbaig35r/snowflake/schemav2026.06.01.1schema.ts

fn create(database: string, name: string, transient: boolean, managed_access: boolean, data_retention_time_in_days: number, default_ddl_collation?: string, comment?: string)

Create a schema via CREATE SCHEMA / CREATE TRANSIENT SCHEMA,

Argument	Type	Required	Description
database	string	yes	Parent database name.
name	string	yes	Schema name (NOT db.schema).
transient	boolean	yes	If true, emits CREATE TRANSIENT SCHEMA. Transient schemas skip
managed_access	boolean	yes	WITH MANAGED ACCESS at create time. In a managed-access schema, only
data_retention_time_in_days	number	yes
default_ddl_collation?	string	no
comment?	string	no

fn read(schema_ref: string)

Fetch live schema state via SHOW SCHEMAS LIKE '<name>' IN DATABASE <db>.

Argument	Type	Required	Description
schema_ref	string	yes

fn list(database: string)

List schemas in a database via SHOW SCHEMAS IN DATABASE <db>.

Argument	Type	Required	Description
database	string	yes

fn adopt(database: string, name: string)

Argument	Type	Required	Description
database	string	yes
name	string	yes

fn update(schema_ref: string)

Update schema settings via ALTER SCHEMA <db>.<name> SET ... . If

Argument	Type	Required	Description
schema_ref	string	yes

fn delete(schema_ref: string, cascade: boolean)

Drop the schema via DROP SCHEMA IF EXISTS <db>.<name> [CASCADE].

Argument	Type	Required	Description
schema_ref	string	yes
cascade	boolean	yes

fn create_or_update(database: string, name: string, transient: boolean, managed_access: boolean, data_retention_time_in_days: number, default_ddl_collation?: string, comment?: string)

Reconcile via account state: SHOW SCHEMAS LIKE for the name in

Argument	Type	Required	Description
database	string	yes	Parent database name.
name	string	yes	Schema name (NOT db.schema).
transient	boolean	yes	If true, emits CREATE TRANSIENT SCHEMA. Transient schemas skip
managed_access	boolean	yes	WITH MANAGED ACCESS at create time. In a managed-access schema, only
data_retention_time_in_days	number	yes
default_ddl_collation?	string	no
comment?	string	no

Resources

schema(infinite)— A Snowflake schema, keyed by '<database>.<schema>'. State

04Previous Versions1

2026.06.01.0Jun 1, 2026

v0.1 (2026.06.01.0) - initial release

First model in the @mfbaig35r/snowflake pack:

@mfbaig35r/snowflake/warehouse: create, read, update, delete, list, adopt, resume, suspend, run_query, wait_statement, cancel_statement, create_or_update. Mirrors the shape of @mfbaig35r/databricks/sql_warehouse so workflows that span both platforms compose cleanly.

Backed by the Snowflake SQL Statement Execution API v2. Auth: PAT (default) or JWT key-pair (RS256, RSA private key resolved via CEL vault.get).

05Stats

100 / 100

Downloads

Archive size

34.8 KB

Has README or module doc2/2earned
README has a code example1/1earned
README is substantive1/1earned
Most symbols documented1/1earned
No slow types1/1earned
Dependencies pass trust audit2/2earned
Has description1/1earned
Platform support declared (or universal)2/2earned
License declared1/1earned
Verified public repository2/2earned

Repository

https://github.com/mfbaig35r/swamp-snowflake

06Platforms

linux · x86_64 linux · aarch64 macOS · x86_64 macOS · aarch64

07Labels

#snowflake #data #pipelines #sql #warehouse #database #schema #secrets #grants