drop _xcom_archive table if it exists

apache · Nov 26, 2024 · 59e3756 · 59e3756
1 parent 2077b9e
commit 59e3756
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/airflow/migrations/versions/0050_3_0_0_remove_pickled_data_from_xcom_table.py b/airflow/migrations/versions/0050_3_0_0_remove_pickled_data_from_xcom_table.py
@@ -180,3 +180,4 @@ def downgrade():
 
         with op.batch_alter_table("xcom", schema=None) as batch_op:
             batch_op.drop_column("value_old")
+    op.drop_table("_xcom_archive", if_exists=True)
diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-7e6189547c880bdbd8760f9b7d90919d3e1d08ef2477210dcf68a4edf8d0bcea
+b3073ec4d411d6bf9aa6388840c7dbb52ed0ca40817d3e4bd76c7ce7f298ea74
Original file line number	Diff line number	Diff line change
Expand Up		@@ -180,3 +180,4 @@ def downgrade():

		with op.batch_alter_table("xcom", schema=None) as batch_op:
		batch_op.drop_column("value_old")
		op.drop_table("_xcom_archive", if_exists=True)
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		7e6189547c880bdbd8760f9b7d90919d3e1d08ef2477210dcf68a4edf8d0bcea
		b3073ec4d411d6bf9aa6388840c7dbb52ed0ca40817d3e4bd76c7ce7f298ea74