# Generic AI output
with DAG(
dag_id='elt',
start_date=days_ago(2),
schedule_interval='@daily',
catchup=False
) as dag:
transform = SnowflakeOperator(
task_id='transform',
snowflake_conn_id='snowflake_default',
sql="""
SELECT *
FROM YOUR_TABLE
WHERE YOUR_COLUMN >= 5000
AND YOUR_DATE_COLUMN >= DATEADD(
DAY, -7, CURRENT_DATE
);
"""
)