Repository navigation

Add e2e test suite for Airflow event-driven DAGs with Apache Kafka - #64833

Merged

jason810496 merged 12 commits into

apache:mainfrom

jason810496:ci/airflow-e2e-tests/event-driven-dag

May 14, 2026

Commits on May 13, 2026

Add e2e test suite for Airflow event-driven DAGs with Apache Kafka

jason810496
authored and
jscheffl
committed
d8a594e
Add 'event_driven' option to E2E test mode in testing_commands.py

jason810496
authored and
jscheffl
committed
ce1d5a7
Address review feedback for event-driven E2E tests

jason810496
authored and
jscheffl
committed
0ae815a
Fix AwaitTrigger and airflow e2e test

jason810496
authored and
jscheffl
committed
e0f8eb8
Add retry for un_pause_dag method

jason810496
authored and
jscheffl
committed
b2916e8
Add additional requirements for Kafka integration in event-driven setup

jason810496
authored and
jscheffl
committed
b1e05d4
Add pytest output

jason810496
authored and
jscheffl
committed
51226fa
fixup: Refactor comments and documentation for consistency in DAG terminology and update regex patterns for Kafka provider paths

jason810496
authored and
jscheffl
committed
e9fa3e0
fixup: Add entry in ci-amd.yml

jason810496
authored and
jscheffl
committed
a224ac1
fixup: Remove debug -sv flag

jason810496
authored and
jscheffl
committed
9771b31

Commits on May 14, 2026

Apply suggestions from code review

jason810496
and
jscheffl
authored
28ec63f
fixup: mount latest provider changes instead of installing from pypi
jason810496
committed
207c702