MINOR: Add Tutorial of scheduling airflow dag with cron expression

coder2j · coder2j · commit d80b1875d6c8 · 2022-02-19T14:36:40.000+01:00
diff --git a/dags/dag_with_cron_expression.py b/dags/dag_with_cron_expression.py
@@ -0,0 +1,23 @@
+from datetime import datetime, timedelta
+
+from airflow import DAG
+from airflow.operators.bash import BashOperator
+
+
+default_args = {
+    'owner': 'coder2j',
+    'retries': 5,
+    'retry_delay': timedelta(minutes=5)
+}
+
+with DAG(
+    default_args=default_args,
+    dag_id="dag_with_cron_expression_v04",
+    start_date=datetime(2021, 11, 1),
+    schedule_interval='0 3 * * Tue-Fri'
+) as dag:
+    task1 = BashOperator(
+        task_id='task1',
+        bash_command="echo dag with cron expression!"
+    )
+    task1
