This is the Flyte SDK (v2) version of this plugin. The Flytekit version is available as flytekitplugins-snowflake.

Snowflake

flyteplugins-snowflake

Flyte SDK (v2)Databases & Warehousessnowflakesqlwarehouseconnector

Run Snowflake SQL queries as Flyte tasks with parameterized inputs, key-pair authentication, batch inserts, and DataFrame support.

Install

pip install flyteplugins-snowflake

Quick Start(example, may need adjustment)

See full examples

pip install flyteplugins-snowflake

from flytekit import task, workflow
from flyteplugins.snowflake import Snowflake, SnowflakeConfig, SnowflakeConnector

config = Snowflake(...)

@task
def my_task() -> None:
    ...

@workflow
def my_workflow() -> None:
    my_task()

Available Imports (3)

configSnowflake

Metadata for a Snowflake query job.

extends dataclass — configuration or data structure for plugin setup

from flyteplugins.snowflake import Snowflake

configSnowflakeConfig

Configure a Snowflake Task using a `SnowflakeConfig` object.

extends dataclass — configuration or data structure for plugin setup

from flyteplugins.snowflake import SnowflakeConfig

connectorSnowflakeConnector

Backend connector for Snowflake.

from flyteplugins.snowflake import SnowflakeConnector

Related Plugins

BigQuery

Databases & Warehouses

This plugin provides BigQuery integration for Flyte, enabling you to run BigQuery queries as Flyte tasks.

Snowflake

Databases & Warehouses

Snowflake enables us to build data-intensive applications without operational burden. Flyte backend can be connected with the Snowflake service. Once enabled, it can allow you to query a Snowflake service.

Bigquery

Databases & Warehouses

BigQuery enables us to build data-intensive applications without operational burden. Flyte backend can be connected with the BigQuery service. Once enabled, it can allow you to query a BigQuery table.