From 452ee4ed3e4d00bb5c6f08503a1459b4492e7cb1 Mon Sep 17 00:00:00 2001 From: Markus Fischer Date: Thu, 19 Feb 2026 11:30:00 +0000 Subject: [PATCH] Add Airflow DAG skeleton for events ETL --- dags/events_dag.py | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 dags/events_dag.py diff --git a/dags/events_dag.py b/dags/events_dag.py new file mode 100644 index 0000000..7ef8495 --- /dev/null +++ b/dags/events_dag.py @@ -0,0 +1,22 @@ +from datetime import datetime, timedelta +from airflow import DAG +from airflow.operators.python import PythonOperator + +default_args = { + "owner": "data-team", + "retries": 2, + "retry_delay": timedelta(minutes=5), + "email_on_failure": True, + "email": ["data-alerts@nexus.local"], +} + +with DAG( + "events_etl", + default_args=default_args, + description="Nightly events ETL from S3 to Redshift", + schedule_interval="0 1 * * *", + start_date=datetime(2024, 9, 1), + catchup=False, + tags=["etl", "events"], +) as dag: + pass # operators wired in separate task modules