Data Engineering, Elt Pipeline, Apache Airflow, Kinesis Firehose, Snowflake Data Cloud.
snowflake_conn_id=SNOWFLAKE_CONN_ID, sql=snowflake_query_customers, warehouse="PRO_CURATION", database="PRO_DB", schema="PRO_SCHEMA", role="PRO_DEVELOPER_ROLE", ) snowflake_order_customers_small_transformation = SnowflakeOperator( task_id='snowflake_order_customers_small_transformation', dag=dag,