Data Engineering, Elt Pipeline, Apache Airflow, Kinesis Firehose, Snowflake Data Cloud.
snowflake_conn_id=SNOWFLAKE_CONN_ID, sql=snowflake_query_customer_orders_small_transformation, warehouse="PRO_CURATION", database="PRO_DB", schema="PRO_SCHEMA", role="PRO_DEVELOPER_ROLE", ) [task_customer_landing_to_processing >> snowflake_customers_sql_str >>