diff --git a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
index ccd9896d4e7..f0de459f03b 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/airflow/metadata.py
@@ -371,7 +371,11 @@ class AirflowSource(PipelineServiceSource):
         offset = 0  # Start
 
         while True:
-            paginated_query = session_query.limit(limit).offset(offset)
+            paginated_query = (
+                session_query.order_by(SerializedDagModel.dag_id.asc())
+                .limit(limit)
+                .offset(offset)
+            )
             results = paginated_query.all()
             if not results:
                 break