This is an automated email from the ASF dual-hosted git repository.
weilee pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 8e812f24995 fixup! [v3-0-test] Switch the Supervisor/task process from
line-based to length-prefixed (#51699) (#51924) (#51641)
8e812f24995 is described below
commit 8e812f24995b23c5ccfe251d9af73182667abebc
Author: Wei Lee <[email protected]>
AuthorDate: Mon Jun 23 23:46:27 2025 +0800
fixup! [v3-0-test] Switch the Supervisor/task process from line-based to
length-prefixed (#51699) (#51924) (#51641)
---
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
.../src/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py | 5 +++++
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/airflow-core/docs/img/airflow_erd.sha256
b/airflow-core/docs/img/airflow_erd.sha256
index 7536fe31e5c..2d2c19551b3 100644
--- a/airflow-core/docs/img/airflow_erd.sha256
+++ b/airflow-core/docs/img/airflow_erd.sha256
@@ -1 +1 @@
-416f82950da2cdf798668327085607268f1c3ebfe5c6b5e22356e370936624fb
\ No newline at end of file
+968bf5c974c4a9663b6be095837d255a2cc8e25ce80209904e672b36edd14148
\ No newline at end of file
diff --git
a/airflow-core/src/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
b/airflow-core/src/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
index e411c8f43c8..2cad82e1e7f 100644
---
a/airflow-core/src/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
+++
b/airflow-core/src/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
@@ -71,8 +71,11 @@ def upgrade():
sa.PrimaryKeyConstraint("id", name=op.f("dag_version_pkey")),
sa.UniqueConstraint("dag_id", "version_number",
name="dag_id_v_name_v_number_unique_constraint"),
)
+
with ignore_sqlite_value_error(), op.batch_alter_table("dag_code") as
batch_op:
batch_op.drop_constraint("dag_code_pkey", type_="primary")
+
+ with op.batch_alter_table("dag_code") as batch_op:
batch_op.drop_column("fileloc_hash")
batch_op.add_column(sa.Column("id", UUIDType(binary=False),
nullable=False))
batch_op.create_primary_key("dag_code_pkey", ["id"])
@@ -91,6 +94,8 @@ def upgrade():
with ignore_sqlite_value_error(), op.batch_alter_table("serialized_dag")
as batch_op:
batch_op.drop_constraint("serialized_dag_pkey", type_="primary")
+
+ with op.batch_alter_table("serialized_dag") as batch_op:
batch_op.drop_index("idx_fileloc_hash")
batch_op.drop_column("fileloc_hash")
batch_op.drop_column("fileloc")
