Соединение воздушного потока создано без пароля и типа соединения

Question

Я пытаюсь создать подключение Snowflake в Airflow программно с помощью DAG. Однако после запуска файла DAG в Airflow соединение создается без пароля и типа соединения. Пожалуйста, порекомендуйте. Код python указан ниже:

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['me@me.com'],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 0,
    'retry_delay': timedelta(minutes=5),
}

dag = DAG(
    'MakeConnection',
    default_args=default_args,
    description='Test',
    schedule_interval=timedelta(days=1),
)

def BuildConnection():

    conn = Connection(
            conn_id='SNOWFLAKECONNECTION',
            conn_type='Snowflake'
            host='abc.snowflakecomputing.com',
            login='AIRFLOW',
            password='123',
            schema='PUBLIC',
            port=443,
            extra=json.dumps(dict(Account='abc')),
            )
    session = settings.Session() # get the session
    session.add(conn)
    session.commit()

run_Rule_SOW = PythonOperator(
    task_id='BuildConnection',
    python_callable=BuildConnection,
    dag=dag,
    )   

Answer 1

Предполагая, что используется разъем Snowflake Python, я думаю, что у вас может быть неправильный параметр для login. Должно быть user. Трудно сказать из вашего поста, что вы видите. Вы получаете сообщение об ошибке, которым можете поделиться?