From 24e5155ffd01f73143dc05ce1c14956bc9ae70fd Mon Sep 17 00:00:00 2001 From: NadezhdaNovotortseva <92038144+NadezhdaNovotortseva@users.noreply.github.com> Date: Sun, 24 Aug 2025 22:49:09 +0300 Subject: [PATCH] fix: airflow ingest get_pipelines_list order_by added (#22909) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix: airflow ingest get_pipelines_list order_by added * code reformatted --------- Co-authored-by: Надежда Коцюба Co-authored-by: Mayur Singal <39544459+ulixius9@users.noreply.github.com> --- .../metadata/ingestion/source/pipeline/airflow/metadata.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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