This is an automated email from the ASF dual-hosted git repository.
rahulvats pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new a61e923898b Fix MySQL sort buffer overflow in deadline alert migration
(#61806)
a61e923898b is described below
commit a61e923898bf87cd346da7c842bc52343f34b4b8
Author: Rahul Vats <[email protected]>
AuthorDate: Mon Feb 16 11:36:57 2026 +0530
Fix MySQL sort buffer overflow in deadline alert migration (#61806)
---
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 142 ++++++++++-----------
.../0099_3_2_0_ui_improvements_for_deadlines.py | 70 +++++++---
3 files changed, 126 insertions(+), 88 deletions(-)
diff --git a/airflow-core/docs/img/airflow_erd.sha256
b/airflow-core/docs/img/airflow_erd.sha256
index 9922fde7709..e4b00e9e893 100644
--- a/airflow-core/docs/img/airflow_erd.sha256
+++ b/airflow-core/docs/img/airflow_erd.sha256
@@ -1 +1 @@
-5fb3647b8dc66e0c22e13797f2b3b05a9c09ac9e4a6d0d82b03f1556197fa219
\ No newline at end of file
+3c93ed6b4ef29ae8f69e3769b59dbd1f2d56ec7c3db7fa86720016d81ffd1058
\ No newline at end of file
diff --git a/airflow-core/docs/img/airflow_erd.svg
b/airflow-core/docs/img/airflow_erd.svg
index 363c06bede7..5918826e5a0 100644
--- a/airflow-core/docs/img/airflow_erd.svg
+++ b/airflow-core/docs/img/airflow_erd.svg
@@ -271,7 +271,7 @@
<text text-anchor="start" x="688" y="-2221.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_bundle--dag_bundle_team -->
-<g id="edge2" class="edge">
+<g id="edge1" class="edge">
<title>dag_bundle:name--dag_bundle_team:dag_bundle_name</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M325,-2479C449.02,-2479 358.98,-2249 483,-2249"/>
<text text-anchor="start" x="452" y="-2237.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -429,7 +429,7 @@
<text text-anchor="start" x="226" y="-1840.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- team--dag_bundle_team -->
-<g id="edge1" class="edge">
+<g id="edge2" class="edge">
<title>team:name--dag_bundle_team:team_name</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M308,-1843C494.34,-1843 296.66,-2224 483,-2224"/>
<text text-anchor="start" x="452" y="-2212.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -705,7 +705,7 @@
<text text-anchor="start" x="1690" y="-2352.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance -->
-<g id="node42" class="node">
+<g id="node43" class="node">
<title>task_instance</title>
<polygon fill="none" stroke="black" points="1799,-1550 1799,-1578 2183,-1578
2183,-1550 1799,-1550"/>
<text text-anchor="start" x="1929.5" y="-1561.2"
font-family="Helvetica,sans-Serif" font-weight="bold"
font-size="16.00">task_instance</text>
@@ -875,7 +875,7 @@
<text text-anchor="start" x="1888" y="-634.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- trigger--task_instance -->
-<g id="edge44" class="edge">
+<g id="edge43" class="edge">
<title>trigger:id--task_instance:trigger_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1690,-2349C1758.26,-2349 1709.9,-2265.77 1718,-2198 1720.41,-2177.82
1777.68,-737 1798,-737"/>
<text text-anchor="start" x="1767" y="-725.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -926,7 +926,7 @@
<text text-anchor="start" x="2422" y="-2392.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- callback--deadline -->
-<g id="edge51" class="edge">
+<g id="edge49" class="edge">
<title>callback:id--deadline:callback_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2142,-2546C2202,-2546 2217,-2546 2277,-2546"/>
<text text-anchor="start" x="2246" y="-2534.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -970,7 +970,7 @@
<text text-anchor="start" x="1149.5" y="-999.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset_alias--asset_alias_asset -->
-<g id="edge5" class="edge">
+<g id="edge6" class="edge">
<title>asset_alias:id--asset_alias_asset:alias_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M785,-1027C882.56,-1027 906.94,-1027 1004.5,-1027"/>
<text text-anchor="start" x="973.5" y="-1015.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -993,7 +993,7 @@
<text text-anchor="start" x="1150.5" y="-895.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset_alias--asset_alias_asset_event -->
-<g id="edge7" class="edge">
+<g id="edge8" class="edge">
<title>asset_alias:id--asset_alias_asset_event:alias_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M785,-1027C892.55,-1027 895.95,-923 1003.5,-923"/>
<text text-anchor="start" x="972.5" y="-911.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1026,7 +1026,7 @@
<text text-anchor="start" x="1136.5" y="-1103.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset_alias--dag_schedule_asset_alias_reference -->
-<g id="edge19" class="edge">
+<g id="edge18" class="edge">
<title>asset_alias:id--dag_schedule_asset_alias_reference:alias_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M785,-1027C885.78,-1027 849.72,-1182 950.5,-1182"/>
<text text-anchor="start" x="919.5" y="-1170.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1074,7 +1074,7 @@
<text text-anchor="start" x="679" y="-1205.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset--asset_alias_asset -->
-<g id="edge6" class="edge">
+<g id="edge5" class="edge">
<title>asset:id--asset_alias_asset:asset_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M787,-1359C972.79,-1359 818.71,-1002 1004.5,-1002"/>
<text text-anchor="start" x="973.5" y="-990.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1182,7 +1182,7 @@
<text text-anchor="start" x="1169.5" y="-1694.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset--task_outlet_asset_reference -->
-<g id="edge23" class="edge">
+<g id="edge22" class="edge">
<title>asset:id--task_outlet_asset_reference:asset_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M787,-1359C828.44,-1359 839.82,-1378.65 863,-1413 901.59,-1470.19
879.8,-1497.73 899,-1564 913.12,-1612.73 918.83,-1624.26 936,-1672
956.26,-1728.31 923.65,-1798 983.5,-1798"/>
<text text-anchor="start" x="952.5" y="-1786.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1220,7 +1220,7 @@
<text text-anchor="start" x="1169.5" y="-1515.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset--task_inlet_asset_reference -->
-<g id="edge25" class="edge">
+<g id="edge24" class="edge">
<title>asset:id--task_inlet_asset_reference:asset_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M787,-1359C931.85,-1359 838.65,-1619 983.5,-1619"/>
<text text-anchor="start" x="952.5" y="-1607.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1248,7 +1248,7 @@
<text text-anchor="start" x="1143.5" y="-1873.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset--asset_dag_run_queue -->
-<g id="edge26" class="edge">
+<g id="edge27" class="edge">
<title>asset:id--asset_dag_run_queue:asset_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M787,-1359C828.44,-1359 841.02,-1377.87 863,-1413 924.73,-1511.66
847.11,-1927 963.5,-1927"/>
<text text-anchor="start" x="932.5" y="-1915.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1301,7 +1301,7 @@
<text text-anchor="start" x="703" y="-173.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset_event--asset_alias_asset_event -->
-<g id="edge8" class="edge">
+<g id="edge7" class="edge">
<title>asset_event:id--asset_alias_asset_event:event_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M785,-377C1036.09,-377 752.41,-898 1003.5,-898"/>
<text text-anchor="start" x="972.5" y="-886.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1387,7 +1387,7 @@
<text text-anchor="start" x="856" y="-3032.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- dag--dag_schedule_asset_alias_reference -->
-<g id="edge18" class="edge">
+<g id="edge19" class="edge">
<title>dag:dag_id--dag_schedule_asset_alias_reference:dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M856,-3029C908.09,-3029 898.41,-1156 950.5,-1156"/>
<text text-anchor="start" x="919.5" y="-1144.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1401,21 +1401,21 @@
<text text-anchor="start" x="846" y="-3032.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- dag--task_outlet_asset_reference -->
-<g id="edge22" class="edge">
+<g id="edge23" class="edge">
<title>dag:dag_id--task_outlet_asset_reference:dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M856,-3029C888.8,-3029 926.08,-1882.26 936,-1851 948.28,-1812.31
942.91,-1773 983.5,-1773"/>
<text text-anchor="start" x="952.5" y="-1761.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="856" y="-3025.3" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- dag--task_inlet_asset_reference -->
-<g id="edge24" class="edge">
+<g id="edge25" class="edge">
<title>dag:dag_id--task_inlet_asset_reference:dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M856,-3029C893.76,-3029 924.74,-1708.04 936,-1672 948.11,-1633.26
942.91,-1594 983.5,-1594"/>
<text text-anchor="start" x="952.5" y="-1582.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="846" y="-3017.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- dag--asset_dag_run_queue -->
-<g id="edge27" class="edge">
+<g id="edge26" class="edge">
<title>dag:dag_id--asset_dag_run_queue:target_dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M856,-3029C885.22,-3029 930.04,-2008.61 936,-1980 943.59,-1943.61
926.32,-1901 963.5,-1901"/>
<text text-anchor="start" x="932.5" y="-1889.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1699,7 +1699,7 @@
<text text-anchor="start" x="1582" y="-191.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_version--dag_run -->
-<g id="edge35" class="edge">
+<g id="edge34" class="edge">
<title>dag_version:id--dag_run:created_dag_version_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1259.5,-2156C1422.54,-2156 1232.96,-695 1396,-695"/>
<text text-anchor="start" x="1365" y="-683.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1843,7 +1843,7 @@
<text text-anchor="start" x="1108.5" y="-387.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- log_template--dag_run -->
-<g id="edge34" class="edge">
+<g id="edge33" class="edge">
<title>log_template:id--dag_run:log_template_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1248.5,-466C1318.16,-466 1326.34,-519 1396,-519"/>
<text text-anchor="start" x="1365" y="-507.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -1899,21 +1899,21 @@
<text text-anchor="start" x="1694" y="-848.8" font-family="Times,serif"
font-size="14.00">{0,1}</text>
</g>
<!-- dag_run--task_instance -->
-<g id="edge41" class="edge">
+<g id="edge44" class="edge">
<title>dag_run:run_id--task_instance:run_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1694,-394C1928.82,-394 1563.18,-912 1798,-912"/>
<text text-anchor="start" x="1767" y="-900.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="1694" y="-382.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- dag_run--task_instance -->
-<g id="edge43" class="edge">
+<g id="edge45" class="edge">
<title>dag_run:dag_id--task_instance:dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1694,-645C1785.62,-645 1706.38,-1463 1798,-1463"/>
<text text-anchor="start" x="1767" y="-1451.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="1694" y="-633.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- backfill_dag_run -->
-<g id="node43" class="node">
+<g id="node44" class="node">
<title>backfill_dag_run</title>
<polygon fill="none" stroke="black" points="1857,-1993 1857,-2021 2126,-2021
2126,-1993 1857,-1993"/>
<text text-anchor="start" x="1919" y="-2004.2"
font-family="Helvetica,sans-Serif" font-weight="bold"
font-size="16.00">backfill_dag_run</text>
@@ -1947,7 +1947,7 @@
<text text-anchor="start" x="2026" y="-1852.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_run--backfill_dag_run -->
-<g id="edge46" class="edge">
+<g id="edge47" class="edge">
<title>dag_run:id--backfill_dag_run:dag_run_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1694,-845C1803.09,-845 1709.91,-1725.21 1754,-1825 1780.29,-1884.51
1790.94,-1930 1856,-1930"/>
<text text-anchor="start" x="1825" y="-1918.8" font-family="Times,serif"
font-size="14.00">0..N</text>
@@ -2060,21 +2060,21 @@
<text text-anchor="start" x="1129.5" y="-541.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- backfill--dag_run -->
-<g id="edge33" class="edge">
+<g id="edge35" class="edge">
<title>backfill:id--dag_run:backfill_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1292.5,-820C1338.5,-820 1350,-820 1396,-820"/>
<text text-anchor="start" x="1365" y="-808.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="1292.5" y="-808.8" font-family="Times,serif"
font-size="14.00">{0,1}</text>
</g>
<!-- backfill--backfill_dag_run -->
-<g id="edge45" class="edge">
+<g id="edge46" class="edge">
<title>backfill:id--backfill_dag_run:backfill_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1292.5,-820C1416.79,-820 1686.81,-1734.43 1754,-1839 1791.29,-1897.04
1787.01,-1956 1856,-1956"/>
<text text-anchor="start" x="1825" y="-1944.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="1292.5" y="-823.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- deadline_alert -->
-<g id="node44" class="node">
+<g id="node42" class="node">
<title>deadline_alert</title>
<polygon fill="none" stroke="black" points="1842,-2279 1842,-2307 2141,-2307
2141,-2279 1842,-2279"/>
<text text-anchor="start" x="1928" y="-2290.2"
font-family="Helvetica,sans-Serif" font-weight="bold"
font-size="16.00">deadline_alert</text>
@@ -2118,12 +2118,19 @@
<text text-anchor="start" x="2023" y="-2088.8"
font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- serialized_dag--deadline_alert -->
-<g id="edge47" class="edge">
+<g id="edge41" class="edge">
<title>serialized_dag:id--deadline_alert:serialized_dag_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M1685,-2145C1758.37,-2145 1767.63,-2091 1841,-2091"/>
<text text-anchor="start" x="1810" y="-2079.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="1685" y="-2133.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
+<!-- deadline_alert--deadline -->
+<g id="edge51" class="edge">
+<title>deadline_alert:id--deadline:deadline_alert_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2142,-2267C2250.35,-2267 2168.65,-2470 2277,-2470"/>
+<text text-anchor="start" x="2246" y="-2458.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2142" y="-2255.8" font-family="Times,serif"
font-size="14.00">{0,1}</text>
+</g>
<!-- hitl_detail -->
<g id="node47" class="node">
<title>hitl_detail</title>
@@ -2239,25 +2246,25 @@
</g>
<!-- task_instance--task_map -->
<g id="edge54" class="edge">
-<title>task_instance:map_index--task_map:map_index</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1238C2258.69,-1238 2220.31,-575 2295,-575"/>
-<text text-anchor="start" x="2264" y="-563.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2184" y="-1226.8" font-family="Times,serif"
font-size="14.00">1</text>
-</g>
-<!-- task_instance--task_map -->
-<g id="edge55" class="edge">
<title>task_instance:run_id--task_map:run_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-912C2352.71,-912 2126.29,-549 2295,-549"/>
<text text-anchor="start" x="2264" y="-537.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2184" y="-900.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
-<g id="edge56" class="edge">
+<g id="edge55" class="edge">
<title>task_instance:dag_id--task_map:dag_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2224.52,-1463 2223.93,-1141.31 2228,-1101 2248.06,-902.26
2204.07,-843.55 2264,-653 2272.19,-626.97 2267.71,-600 2295,-600"/>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2224.63,-1463 2223.92,-1140.42 2228,-1100 2248,-901.7
2204.19,-843.12 2264,-653 2272.19,-626.97 2267.71,-600 2295,-600"/>
<text text-anchor="start" x="2264" y="-588.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2184" y="-1451.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
+<!-- task_instance--task_map -->
+<g id="edge56" class="edge">
+<title>task_instance:map_index--task_map:map_index</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1238C2258.69,-1238 2220.31,-575 2295,-575"/>
+<text text-anchor="start" x="2264" y="-563.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2184" y="-1226.8" font-family="Times,serif"
font-size="14.00">1</text>
+</g>
<!-- task_reschedule -->
<g id="node49" class="node">
<title>task_reschedule</title>
@@ -2348,19 +2355,19 @@
</g>
<!-- task_instance--xcom -->
<g id="edge58" class="edge">
-<title>task_instance:dag_id--xcom:dag_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2222.08,-1463 2224.49,-816.99 2227,-779 2242.69,-541.62
2232.97,-480.87 2264,-245 2273.09,-175.86 2224.27,-91 2294,-91"/>
-<text text-anchor="start" x="2263" y="-79.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2184" y="-1466.8" font-family="Times,serif"
font-size="14.00">1</text>
-</g>
-<!-- task_instance--xcom -->
-<g id="edge59" class="edge">
<title>task_instance:run_id--xcom:run_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-912C2202.66,-912 2261.35,-263.47 2264,-245 2275.47,-165.15
2213.33,-66 2294,-66"/>
<text text-anchor="start" x="2263" y="-54.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2184" y="-915.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
+<g id="edge59" class="edge">
+<title>task_instance:dag_id--xcom:dag_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2222.08,-1463 2224.49,-816.99 2227,-779 2242.69,-541.62
2232.97,-480.87 2264,-245 2273.09,-175.86 2224.27,-91 2294,-91"/>
+<text text-anchor="start" x="2263" y="-79.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2184" y="-1466.8" font-family="Times,serif"
font-size="14.00">1</text>
+</g>
+<!-- task_instance--xcom -->
<g id="edge60" class="edge">
<title>task_instance:map_index--xcom:map_index</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1238C2190.92,-1238 2262.75,-251.8 2264,-245 2272.63,-198.11
2246.32,-142 2294,-142"/>
@@ -2571,32 +2578,32 @@
</g>
<!-- task_instance--task_instance_history -->
<g id="edge63" class="edge">
-<title>task_instance:task_id--task_instance_history:task_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-762C2226.75,-762 2228.25,-803 2271,-803"/>
-<text text-anchor="start" x="2240" y="-791.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2174" y="-750.8" font-family="Times,serif"
font-size="14.00">1</text>
-</g>
-<!-- task_instance--task_instance_history -->
-<g id="edge64" class="edge">
<title>task_instance:map_index--task_instance_history:map_index</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1238C2226.75,-1238 2228.25,-1279 2271,-1279"/>
<text text-anchor="start" x="2240" y="-1267.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2174" y="-1226.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_history -->
-<g id="edge65" class="edge">
-<title>task_instance:dag_id--task_instance_history:dag_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2223.32,-1463 2231.68,-1479 2271,-1479"/>
-<text text-anchor="start" x="2240" y="-1467.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2174" y="-1451.8" font-family="Times,serif"
font-size="14.00">1</text>
+<g id="edge64" class="edge">
+<title>task_instance:task_id--task_instance_history:task_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-762C2226.75,-762 2228.25,-803 2271,-803"/>
+<text text-anchor="start" x="2240" y="-791.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2174" y="-750.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_history -->
-<g id="edge66" class="edge">
+<g id="edge65" class="edge">
<title>task_instance:run_id--task_instance_history:run_id</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-912C2226.75,-912 2228.25,-953 2271,-953"/>
<text text-anchor="start" x="2240" y="-941.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2174" y="-900.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
+<!-- task_instance--task_instance_history -->
+<g id="edge66" class="edge">
+<title>task_instance:dag_id--task_instance_history:dag_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-1463C2223.32,-1463 2231.68,-1479 2271,-1479"/>
+<text text-anchor="start" x="2240" y="-1467.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2174" y="-1451.8" font-family="Times,serif"
font-size="14.00">1</text>
+</g>
<!-- rendered_task_instance_fields -->
<g id="node53" class="node">
<title>rendered_task_instance_fields</title>
@@ -2634,10 +2641,10 @@
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge67" class="edge">
-<title>task_instance:run_id--rendered_task_instance_fields:run_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-912C2247.99,-912 2221.01,-345 2285,-345"/>
-<text text-anchor="start" x="2254" y="-333.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2174" y="-915.8" font-family="Times,serif"
font-size="14.00">1</text>
+<title>task_instance:task_id--rendered_task_instance_fields:task_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-762C2284.75,-762 2184.25,-320 2285,-320"/>
+<text text-anchor="start" x="2254" y="-308.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2174" y="-765.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge68" class="edge">
@@ -2648,10 +2655,10 @@
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge69" class="edge">
-<title>task_instance:task_id--rendered_task_instance_fields:task_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-762C2284.75,-762 2184.25,-320 2285,-320"/>
-<text text-anchor="start" x="2254" y="-308.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2174" y="-765.8" font-family="Times,serif"
font-size="14.00">1</text>
+<title>task_instance:run_id--rendered_task_instance_fields:run_id</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2184,-912C2247.99,-912 2221.01,-345 2285,-345"/>
+<text text-anchor="start" x="2254" y="-333.8" font-family="Times,serif"
font-size="14.00">0..N</text>
+<text text-anchor="start" x="2174" y="-915.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge70" class="edge">
@@ -2660,13 +2667,6 @@
<text text-anchor="start" x="2254" y="-359.8" font-family="Times,serif"
font-size="14.00">0..N</text>
<text text-anchor="start" x="2174" y="-1241.8" font-family="Times,serif"
font-size="14.00">1</text>
</g>
-<!-- deadline_alert--deadline -->
-<g id="edge49" class="edge">
-<title>deadline_alert:id--deadline:deadline_alert_id</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2"
d="M2142,-2267C2250.35,-2267 2168.65,-2470 2277,-2470"/>
-<text text-anchor="start" x="2246" y="-2458.8" font-family="Times,serif"
font-size="14.00">0..N</text>
-<text text-anchor="start" x="2142" y="-2255.8" font-family="Times,serif"
font-size="14.00">{0,1}</text>
-</g>
<!-- hitl_detail_history -->
<g id="node54" class="node">
<title>hitl_detail_history</title>
diff --git
a/airflow-core/src/airflow/migrations/versions/0099_3_2_0_ui_improvements_for_deadlines.py
b/airflow-core/src/airflow/migrations/versions/0099_3_2_0_ui_improvements_for_deadlines.py
index 581b38caaa2..4188254ca2e 100644
---
a/airflow-core/src/airflow/migrations/versions/0099_3_2_0_ui_improvements_for_deadlines.py
+++
b/airflow-core/src/airflow/migrations/versions/0099_3_2_0_ui_improvements_for_deadlines.py
@@ -389,17 +389,36 @@ def
migrate_existing_deadline_alert_data_from_serialized_dag() -> None:
while True:
batch_num += 1
- result = conn.execute(
- sa.text("""
- SELECT id, dag_id, data, data_compressed, created_at
- FROM serialized_dag
- WHERE (data IS NOT NULL OR data_compressed IS NOT NULL)
- AND dag_id > :last_dag_id
- ORDER BY dag_id
- LIMIT :batch_size
- """),
- {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
- )
+ if dialect == "mysql":
+ # Avoid selecting large columns during ORDER BY to prevent sort
buffer overflow
+ result = conn.execute(
+ sa.text("""
+ SELECT sd.id, sd.dag_id, sd.data, sd.data_compressed,
sd.created_at
+ FROM serialized_dag sd
+ INNER JOIN (
+ SELECT id, dag_id
+ FROM serialized_dag
+ WHERE (data IS NOT NULL OR data_compressed IS NOT NULL)
+ AND dag_id > :last_dag_id
+ ORDER BY dag_id
+ LIMIT :batch_size
+ ) AS subq ON sd.id = subq.id
+ ORDER BY sd.dag_id
+ """),
+ {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
+ )
+ else:
+ result = conn.execute(
+ sa.text("""
+ SELECT id, dag_id, data, data_compressed, created_at
+ FROM serialized_dag
+ WHERE (data IS NOT NULL OR data_compressed IS NOT NULL)
+ AND dag_id > :last_dag_id
+ ORDER BY dag_id
+ LIMIT :batch_size
+ """),
+ {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
+ )
batch_results = list(result)
if not batch_results:
@@ -590,17 +609,36 @@ def migrate_deadline_alert_data_back_to_serialized_dag()
-> None:
while True:
batch_num += 1
- result = conn.execute(
- sa.text("""
+ if dialect == "mysql":
+ # Avoid selecting large columns during ORDER BY to prevent sort
buffer overflow
+ result = conn.execute(
+ sa.text("""
+ SELECT sd.id, sd.dag_id, sd.data, sd.data_compressed
+ FROM serialized_dag sd
+ INNER JOIN (
+ SELECT id, dag_id
+ FROM serialized_dag
+ WHERE (data IS NOT NULL OR data_compressed IS NOT NULL)
+ AND dag_id > :last_dag_id
+ ORDER BY dag_id
+ LIMIT :batch_size
+ ) AS subq ON sd.id = subq.id
+ ORDER BY sd.dag_id
+ """),
+ {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
+ )
+ else:
+ result = conn.execute(
+ sa.text("""
SELECT id, dag_id, data, data_compressed
FROM serialized_dag
WHERE (data IS NOT NULL OR data_compressed IS NOT NULL)
AND dag_id > :last_dag_id
ORDER BY dag_id
LIMIT :batch_size
- """),
- {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
- )
+ """),
+ {"last_dag_id": last_dag_id, "batch_size": BATCH_SIZE},
+ )
batch_results = list(result)
if not batch_results:
