[FIXED] Python SnowflakeOperator setup snowflake_default

Issue

Good day, I cannot find how to do basic setup to airflow.contrib.operators.snowflake_operator.SnowflakeOperatorto connect to snowflake. snowflake.connector.connect works fine.

When I do it with SnowflakeOperator :

op = snowflake_operator.SnowflakeOperator(sql = "create table test(*****)", task_id = '123')

I get the

airflow.exceptions.AirflowException: The conn_idsnowflake_defaultisn't defined

I tried to insert in backend sqlite db

INSERT INTO connection( conn_id, conn_type, host , schema, login, password , port, is_encrypted, is_extra_encrypted ) VALUES (*****)

But after it I get an error:

snowflake.connector.errors.ProgrammingError: 251001: None: Account must be specified.

Passing account kwarg into SnowflakeOperator constructor does not help. It seems I cannot pass account into db or into constructor, but it's required.

Please help me, let me know what data I should insert into backend local db to be able to connect via SnowflakeOperator

Solution

Go to Admin -> Connections and update snowflake_default connection like this:

based on source code airflow/contrib/hooks/snowflake_hook.py:53 we need to add extras like this:

{
    "schema": "schema",
    "database": "database",
    "account": "account",
    "warehouse": "warehouse"
}

Answered By - Andrii Soldatenko