Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion RELEASE_NOTES.rst
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ Bug Fixes
- Fix ``AttributeError`` when reading logs for previous task attempts with ``TaskInstanceHistory`` (#54114)
- Skip database queries for spans and metrics when tracing/metrics are disabled (#54404)
- UI: Fix Graph view edge rendering issues for nested task groups with excessive bends and misalignment (#54412)
- Allow database downgrade from Airflow 3.x to 2.11 (#54399)
- Allow database downgrade from Airflow 3.x to 2.11 (#54399, #54508)
- Reduce excessive warning logs when multiple deferred tasks are queued in triggerer (#54441)
- Fix log retrieval failures for in-progress tasks by properly configuring JWT authentication (#54444)
- Fix DAG import errors for invalid access control roles to persist consistently in UI (#54432)
Expand Down
2 changes: 1 addition & 1 deletion airflow-core/docs/img/airflow_erd.sha256
Original file line number Diff line number Diff line change
@@ -1 +1 @@
47bc0fb61cdb68be06d02c7f7d88bf39c0d454bd23e9ad924e218999c40fc121
9650b3ecb443b35b5626dede72e6235683f616f16c8c8f5ab113fa08d1a27ff7
Original file line number Diff line number Diff line change
Expand Up @@ -143,12 +143,10 @@ def downgrade():
elif dialect_name == "mysql":
op.execute(
"""
UPDATE task_instance_history tih
JOIN (
SELECT id, ROW_NUMBER() OVER (ORDER BY id) AS row_num
FROM task_instance_history
) AS temp ON tih.id = temp.id
SET tih.id = temp.row_num;
SET @row_number = 0;
UPDATE task_instance_history
SET id = (@row_number := @row_number + 1)
ORDER BY try_id;
"""
)
else:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ def downgrade():
dialect_name = conn.dialect.name
with op.batch_alter_table("task_reschedule", schema=None) as batch_op:
batch_op.add_column(
sa.Column("try_number", sa.INTEGER(), autoincrement=False, nullable=False, default=1)
sa.Column("try_number", sa.INTEGER(), autoincrement=False, nullable=False, server_default="1")
)

with op.batch_alter_table("task_instance_note", schema=None) as batch_op:
Expand All @@ -117,5 +117,5 @@ def downgrade():
# (and on non sqlite batching isn't "a thing", it issue alter tables fine)
with op.batch_alter_table("task_instance_history", schema=None) as batch_op:
batch_op.add_column(
sa.Column("task_instance_id", UUIDType(binary=False), autoincrement=False, nullable=False)
sa.Column("task_instance_id", UUIDType(binary=False), autoincrement=False, nullable=True)
)
4 changes: 2 additions & 2 deletions reproducible_build.yaml
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
release-notes-hash: 5df5110dd4c2d2b9b1d1a65256c11961
source-date-epoch: 1755097670
release-notes-hash: 7a4e51bb2b808cfa090444eb05ebc2bf
source-date-epoch: 1755194406
Loading