# Astro IDE output (Airflow 3)
_SNOWFLAKE_CONN_ID = "HQ_PROD"
_REVENUE_TABLE = "HQ.PROD.REVENUE"

@dag(
  schedule="@daily",
  default_args={"retries":3},
  template_searchpath=["include/sql"],
)
def elt():
  transform = SQLExecuteQueryOperator(
      task_id='transform'
      conn_id=_SNOWFLAKE_CONN_ID,
      sql="revenue_transformation.sql"
      params={"revenue_table": _REVENUE_TABLE}
  )
elt()