Skip to content

Commit ebdbf31

Browse files
committed
Fix order by
1 parent 3434103 commit ebdbf31

File tree

1 file changed

+2
-3
lines changed
  • airflow/api_fastapi/core_api/routes/public

1 file changed

+2
-3
lines changed

airflow/api_fastapi/core_api/routes/public/xcom.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
from sqlalchemy.orm import Session
2525

2626
from airflow.api_fastapi.common.db.common import get_session, paginated_select
27-
from airflow.api_fastapi.common.parameters import QueryLimit, QueryOffset, SortParam
27+
from airflow.api_fastapi.common.parameters import QueryLimit, QueryOffset
2828
from airflow.api_fastapi.common.router import AirflowRouter
2929
from airflow.api_fastapi.core_api.datamodels.xcom import (
3030
XComCollection,
@@ -135,11 +135,10 @@ def get_xcom_entries(
135135

136136
query, total_entries = paginated_select(
137137
statement=query,
138-
filters=[],
139-
order_by=SortParam(["dag_id", "task_id", "run_id", "map_index", "key"], XCom),
140138
offset=offset,
141139
limit=limit,
142140
session=session,
143141
)
142+
query = query.order_by(XCom.dag_id, XCom.task_id, XCom.run_id, XCom.map_index, XCom.key)
144143
xcoms = session.scalars(query)
145144
return XComCollection(xcom_entries=xcoms, total_entries=total_entries)

0 commit comments

Comments
 (0)