This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 2149b4dbee Ensures DAG params order regardless of backend (#40156)
add fa65a20d4a local task job: add timeout, to not kill
on_task_instance_success listener prematurely (#39890)
No new revisions were added by this update.
Summary of changes:
airflow/config_templates/config.yml | 8 ++
airflow/jobs/local_task_job_runner.py | 9 +-
airflow/providers/openlineage/plugins/listener.py | 1 -
tests/dags/test_mark_state.py | 17 +++
tests/jobs/test_local_task_job.py | 117 ++++++++++++++++++++-
.../{throwing_listener.py => slow_listener.py} | 9 +-
...{throwing_listener.py => very_slow_listener.py} | 9 +-
7 files changed, 155 insertions(+), 15 deletions(-)
copy tests/listeners/{throwing_listener.py => slow_listener.py} (94%)
copy tests/listeners/{throwing_listener.py => very_slow_listener.py} (94%)
