• Home
• Index

Index

_

__version__ (in module airflow.providers.snowflake)

A

account_identifier (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook property) airflow.providers.snowflake module airflow.providers.snowflake.decorators module airflow.providers.snowflake.decorators.snowpark module airflow.providers.snowflake.hooks module airflow.providers.snowflake.hooks.snowflake module airflow.providers.snowflake.hooks.snowflake_sql_api module airflow.providers.snowflake.operators module airflow.providers.snowflake.operators.snowflake module airflow.providers.snowflake.operators.snowpark module

airflow.providers.snowflake.transfers module airflow.providers.snowflake.transfers.copy_into_snowflake module airflow.providers.snowflake.triggers module airflow.providers.snowflake.triggers.snowflake_trigger module airflow.providers.snowflake.utils module airflow.providers.snowflake.utils.common module airflow.providers.snowflake.utils.openlineage module airflow.providers.snowflake.utils.snowpark module airflow.providers.snowflake.utils.sql_api_generate_jwt module ALGORITHM (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator attribute)

C

calculate_public_key_fingerprint() (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator method) check_query_output() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) conn_id_field (airflow.providers.snowflake.operators.snowflake.SnowflakeCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeIntervalCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeValueCheckOperator attribute)

conn_name_attr (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook attribute) conn_type (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook attribute) copy_into_table (in module tests.system.snowflake.example_copy_into_snowflake) CopyFromExternalStageToSnowflakeOperator (class in airflow.providers.snowflake.transfers.copy_into_snowflake) CREATE_TABLE_SQL_STRING (in module tests.system.snowflake.example_snowflake)

D

DAG_ID (in module tests.system.snowflake.example_copy_into_snowflake) (in module tests.system.snowflake.example_snowflake) (in module tests.system.snowflake.example_snowpark_decorator) (in module tests.system.snowflake.example_snowpark_operator)

default_conn_name (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook attribute)

E

enclose_param() (in module airflow.providers.snowflake.utils.common) ENV_ID (in module tests.system.snowflake.example_copy_into_snowflake) (in module tests.system.snowflake.example_snowflake) execute() (airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator method) (airflow.providers.snowflake.transfers.copy_into_snowflake.CopyFromExternalStageToSnowflakeOperator method)

execute_callable() (airflow.providers.snowflake.operators.snowpark.SnowparkOperator method) execute_complete() (airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator method) execute_query() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) EXPIRE_TIME (in module airflow.providers.snowflake.utils.sql_api_generate_jwt)

F

fix_account_name() (in module airflow.providers.snowflake.utils.openlineage)

fix_snowflake_sqlalchemy_uri() (in module airflow.providers.snowflake.utils.openlineage)

G

get_autocommit() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_conn() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_connection_form_widgets() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook class method) get_headers() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_oauth_token() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_openlineage_database_dialect() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_openlineage_database_info() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_openlineage_database_specific_lineage() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_openlineage_default_schema() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_openlineage_facets_on_complete() (airflow.providers.snowflake.transfers.copy_into_snowflake.CopyFromExternalStageToSnowflakeOperator method)

get_private_key() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_query_status() (airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger method) get_request_url_header_params() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_snowpark_session() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_sql_api_query_status() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_sql_api_query_status_async() (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook method) get_sqlalchemy_engine() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) get_token() (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator method) get_ui_field_behaviour() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook class method) get_uri() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method)

H

hook_name (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook attribute)

I

inject_session_into_op_kwargs() (in module airflow.providers.snowflake.utils.snowpark)

ISSUE_TIME (in module airflow.providers.snowflake.utils.sql_api_generate_jwt) ISSUER (in module airflow.providers.snowflake.utils.sql_api_generate_jwt)

J

JWTGenerator (class in airflow.providers.snowflake.utils.sql_api_generate_jwt)

L

LIFETIME (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator attribute) (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator attribute)

logger (in module airflow.providers.snowflake.utils.sql_api_generate_jwt)

M

module airflow.providers.snowflake airflow.providers.snowflake.decorators airflow.providers.snowflake.decorators.snowpark airflow.providers.snowflake.hooks airflow.providers.snowflake.hooks.snowflake airflow.providers.snowflake.hooks.snowflake_sql_api airflow.providers.snowflake.operators airflow.providers.snowflake.operators.snowflake airflow.providers.snowflake.operators.snowpark airflow.providers.snowflake.transfers airflow.providers.snowflake.transfers.copy_into_snowflake airflow.providers.snowflake.triggers airflow.providers.snowflake.triggers.snowflake_trigger airflow.providers.snowflake.utils airflow.providers.snowflake.utils.common airflow.providers.snowflake.utils.openlineage airflow.providers.snowflake.utils.snowpark airflow.providers.snowflake.utils.sql_api_generate_jwt tests.system.snowflake tests.system.snowflake.example_copy_into_snowflake tests.system.snowflake.example_snowflake tests.system.snowflake.example_snowpark_decorator tests.system.snowflake.example_snowpark_operator

P

poll_on_queries() (airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator method)

prepare_account_name_for_jwt() (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator method)

R

RENEWAL_DELTA (airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator attribute) (airflow.providers.snowflake.utils.sql_api_generate_jwt.JWTGenerator attribute)

run() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) (airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger method)

S

S3_FILE_PATH (in module tests.system.snowflake.example_copy_into_snowflake) serialize() (airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger method) set_autocommit() (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook method) setup_data() (in module tests.system.snowflake.example_snowpark_decorator) (in module tests.system.snowflake.example_snowpark_operator) SNOWFLAKE_CONN_ID (in module tests.system.snowflake.example_copy_into_snowflake) (in module tests.system.snowflake.example_snowflake) (in module tests.system.snowflake.example_snowpark_decorator) (in module tests.system.snowflake.example_snowpark_operator) snowflake_op_sql_str (in module tests.system.snowflake.example_snowflake) SNOWFLAKE_SAMPLE_TABLE (in module tests.system.snowflake.example_copy_into_snowflake) (in module tests.system.snowflake.example_snowflake) SNOWFLAKE_STAGE (in module tests.system.snowflake.example_copy_into_snowflake) SnowflakeCheckOperator (class in airflow.providers.snowflake.operators.snowflake)

SnowflakeHook (class in airflow.providers.snowflake.hooks.snowflake) SnowflakeIntervalCheckOperator (class in airflow.providers.snowflake.operators.snowflake) SnowflakeOperator (class in airflow.providers.snowflake.operators.snowflake) SnowflakeSqlApiHook (class in airflow.providers.snowflake.hooks.snowflake_sql_api) SnowflakeSqlApiOperator (class in airflow.providers.snowflake.operators.snowflake) SnowflakeSqlApiTrigger (class in airflow.providers.snowflake.triggers.snowflake_trigger) SnowflakeValueCheckOperator (class in airflow.providers.snowflake.operators.snowflake) snowpark_task() (in module airflow.providers.snowflake.decorators.snowpark) SnowparkOperator (class in airflow.providers.snowflake.operators.snowpark) SQL_INSERT_STATEMENT (in module tests.system.snowflake.example_snowflake) SQL_LIST (in module tests.system.snowflake.example_snowflake) SQL_MULTIPLE_STMTS (in module tests.system.snowflake.example_snowflake) SUBJECT (in module airflow.providers.snowflake.utils.sql_api_generate_jwt) supports_autocommit (airflow.providers.snowflake.hooks.snowflake.SnowflakeHook attribute)

T

T (in module airflow.providers.snowflake.hooks.snowflake) template_ext (airflow.providers.snowflake.operators.snowflake.SnowflakeCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeOperator attribute) template_fields (airflow.providers.snowflake.operators.snowflake.SnowflakeCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeIntervalCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeValueCheckOperator attribute) (airflow.providers.snowflake.transfers.copy_into_snowflake.CopyFromExternalStageToSnowflakeOperator attribute) template_fields_renderers (airflow.providers.snowflake.operators.snowflake.SnowflakeOperator attribute) (airflow.providers.snowflake.transfers.copy_into_snowflake.CopyFromExternalStageToSnowflakeOperator attribute) test_run (in module tests.system.snowflake.example_copy_into_snowflake) (in module tests.system.snowflake.example_snowflake) (in module tests.system.snowflake.example_snowpark_decorator) (in module tests.system.snowflake.example_snowpark_operator)

tests.system.snowflake module tests.system.snowflake.example_copy_into_snowflake module tests.system.snowflake.example_snowflake module tests.system.snowflake.example_snowpark_decorator module tests.system.snowflake.example_snowpark_operator module

U

ui_color (airflow.providers.snowflake.operators.snowflake.SnowflakeCheckOperator attribute) (airflow.providers.snowflake.operators.snowflake.SnowflakeOperator attribute)

PreviousNext

Was this entry helpful?