This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a commit to branch v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit bf15b25c3bff3d2026cc724f99f3865dbda354d7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Oct 30 00:59:13 2026 +0530
[v3-4-test] Don't force dags reserialize in e2e startup (races
dag-processor) (#75739) (#75941)
(cherry picked from commit 6a8e86429394e8b72d0f720ada1c106b91e7b603)
Co-authored-by: Rahul Vats <[email protected]>
---
airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py
b/airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py
index 09331b1645d..ecb6bbe3ed2 100644
--- a/airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py
+++ b/airflow-e2e-tests/tests/airflow_e2e_tests/conftest.py
@@ -982,9 +982,8 @@ def spin_up_airflow_environment(tmp_path_factory:
pytest.TempPathFactory):
_E2ETestState.compose_instance.start()
_E2ETestState.compose_instance.wait_for(f"http://{DOCKER_COMPOSE_HOST_PORT}/api/v2/monitor/health";)
- _E2ETestState.compose_instance.exec_in_container(
- command=["airflow", "dags", "reserialize"],
service_name="airflow-dag-processor"
- )
+ # No forced `dags reserialize`: it races the live dag-processor on the
same dag_id INSERT
+ # (dag_pkey crash). The processor serializes Dags itself and tests
poll via wait_for_dag.
if E2E_TEST_MODE == "event_driven":
console.print("[yellow]Creating Kafka topics...")
