小编Cyp*_*pho的帖子

正如您在代码示例中看到的，我试图通过 Airflow DAG 任务将 session_parameters 传递到我的 Snowflake 连接，但该参数没有被拾取，有什么解决方案吗？

task = SnowflakeOperator(
    task_id='Task',
    sql="CREATE OR REPLACE TABLE MY_DB.MY_SCHEMA.MY_TABLE (test VARCHAR)",
    session_parameters={
        "QUERY_TAG": "my_tag"
    },
    snowflake_conn_id="snowflake_connection",
    warehouse="MY_WH",
    dag=dag,
)