tests.system.snowflake.example_snowflake¶

Example use of Snowflake related operators.

Attributes¶

`SNOWFLAKE_CONN_ID`
`SNOWFLAKE_SAMPLE_TABLE`
`SNOWFLAKE_CHECK_TABLE`
`CREATE_TABLE_SQL_STRING`
`CREATE_CHECK_TABLE_SQL_STRING`
`SQL_INSERT_STATEMENT`
`SQL_LIST`
`SQL_MULTIPLE_STMTS`
`SQL_CHECK_TABLE_INSERT`
`ENV_ID`
`DAG_ID`
`snowflake_op_sql_str`
`test_run`

tests.system.snowflake.example_snowflake.SNOWFLAKE_CONN_ID = 'my_snowflake_conn'[source]¶

tests.system.snowflake.example_snowflake.SNOWFLAKE_SAMPLE_TABLE = 'sample_table'[source]¶

tests.system.snowflake.example_snowflake.SNOWFLAKE_CHECK_TABLE = 'sample_check_table'[source]¶

tests.system.snowflake.example_snowflake.CREATE_TABLE_SQL_STRING = 'CREATE OR REPLACE TRANSIENT TABLE sample_table (name VARCHAR(250), id INT);'[source]¶

tests.system.snowflake.example_snowflake.CREATE_CHECK_TABLE_SQL_STRING = Multiline-String[source]¶

Show Value

"""
CREATE OR REPLACE TRANSIENT TABLE sample_check_table (
    ds DATE,
    value INT
);
"""

tests.system.snowflake.example_snowflake.SQL_INSERT_STATEMENT = "INSERT INTO sample_table VALUES ('name', %(id)s)"[source]¶

tests.system.snowflake.example_snowflake.SQL_CHECK_TABLE_INSERT = Multiline-String[source]¶

Show Value

"""
INSERT INTO sample_check_table (ds, value)
VALUES
    (TO_DATE('{{ ds }}'), 4),
    (TO_DATE('{{ macros.ds_add(ds, -1) }}'), 4)
"""

tests.system.snowflake.example_snowflake.DAG_ID = 'example_snowflake'[source]¶