We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 21c15cb commit 757db27Copy full SHA for 757db27
airflow-core/src/airflow/models/serialized_dag.py
@@ -461,6 +461,15 @@ def write_dag(
461
462
@classmethod
463
def latest_item_select_object(cls, dag_id):
464
+ from airflow.settings import engine
465
+
466
+ if engine.dialect.name == "mysql":
467
+ # Prevent "Out of sort memory" caused by large values in cls.data column for MySQL.
468
+ # Details in https://github.com/apache/airflow/pull/55589
469
+ latest_item_id = (
470
+ select(cls.id).where(cls.dag_id == dag_id).order_by(cls.created_at.desc()).limit(1)
471
+ )
472
+ return select(cls).where(cls.id == latest_item_id)
473
return select(cls).where(cls.dag_id == dag_id).order_by(cls.created_at.desc()).limit(1)
474
475
0 commit comments