From c899bdf5b523a65ada75ab730c4c8301934adc19 Mon Sep 17 00:00:00 2001
From: venkatamandavilli-code <venkata.mandavilli@gmail.com>
Date: Tue, 12 May 2026 09:47:51 -0500
Subject: [PATCH 1/2] Add example ERP migration pipeline DAG

---
 .../example_erp_migration_pipeline.py         | 59 +++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 airflow/example_dags/example_erp_migration_pipeline.py

diff --git a/airflow/example_dags/example_erp_migration_pipeline.py b/airflow/example_dags/example_erp_migration_pipeline.py
new file mode 100644
index 0000000000000..9ab6470df4a35
--- /dev/null
+++ b/airflow/example_dags/example_erp_migration_pipeline.py
@@ -0,0 +1,59 @@
+from datetime import datetime
+from airflow import DAG
+from airflow.operators.python import PythonOperator
+
+
+def extract_data(**kwargs):
+    print("Extracting data from legacy ERP system")
+
+
+def validate_data(**kwargs):
+    print("Validating data (completeness, accuracy checks)")
+
+
+def transform_data(**kwargs):
+    print("Transforming data to target ERP format")
+
+
+def load_data(**kwargs):
+    print("Loading data into target system")
+
+
+def reconcile_data(**kwargs):
+    print("Reconciling source and target data")
+
+
+with DAG(
+    dag_id="example_erp_migration_pipeline",
+    start_date=datetime(2024, 1, 1),
+    schedule=None,
+    catchup=False,
+    tags=["example", "erp", "migration"],
+) as dag:
+
+    extract = PythonOperator(
+        task_id="extract_data",
+        python_callable=extract_data,
+    )
+
+    validate = PythonOperator(
+        task_id="validate_data",
+        python_callable=validate_data,
+    )
+
+    transform = PythonOperator(
+        task_id="transform_data",
+        python_callable=transform_data,
+    )
+
+    load = PythonOperator(
+        task_id="load_data",
+        python_callable=load_data,
+    )
+
+    reconcile = PythonOperator(
+        task_id="reconcile_data",
+        python_callable=reconcile_data,
+    )
+
+    extract >> validate >> transform >> load >> reconcile

From 9803e0d1a5c3bb8b888c956332a7b3feccc943c3 Mon Sep 17 00:00:00 2001
From: venkatamandavilli-code <venkata.mandavilli@gmail.com>
Date: Tue, 12 May 2026 13:34:33 -0500
Subject: [PATCH 2/2] Improve ERP migration example DAG documentation

---
 .../example_erp_migration_pipeline.py             | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/airflow/example_dags/example_erp_migration_pipeline.py b/airflow/example_dags/example_erp_migration_pipeline.py
index 9ab6470df4a35..07a8b9fb6a794 100644
--- a/airflow/example_dags/example_erp_migration_pipeline.py
+++ b/airflow/example_dags/example_erp_migration_pipeline.py
@@ -1,25 +1,40 @@
+"""
+Example DAG: ERP Data Migration Pipeline
+
+This example demonstrates a structured ETL workflow including:
+extract, validate, transform, load, and reconcile steps.
+
+It is a simplified illustration of how Apache Airflow can be used
+to orchestrate enterprise ERP data migration processes.
+"""
+
 from datetime import datetime
 from airflow import DAG
 from airflow.operators.python import PythonOperator
 
 
 def extract_data(**kwargs):
+    """Simulates extraction from a legacy ERP system."""
     print("Extracting data from legacy ERP system")
 
 
 def validate_data(**kwargs):
+    """Simulates validation checks for completeness and accuracy."""
     print("Validating data (completeness, accuracy checks)")
 
 
 def transform_data(**kwargs):
+    """Simulates transforming source data into the target ERP format."""
     print("Transforming data to target ERP format")
 
 
 def load_data(**kwargs):
+    """Simulates loading transformed data into the target system."""
     print("Loading data into target system")
 
 
 def reconcile_data(**kwargs):
+    """Simulates source-to-target reconciliation after loading."""
     print("Reconciling source and target data")