You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2022/11/22 20:09:36 UTC
[airflow] branch main updated (aaf5fd6fd8 -> 035315f5cf)
This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from aaf5fd6fd8 Add better diagnostics in case of outdated images for pre-commits (#27835)
add 035315f5cf Add DagRun state change to the Listener plugin system(#27113)
No new revisions were added by this update.
Summary of changes:
airflow/jobs/backfill_job.py | 2 +
airflow/jobs/base_job.py | 3 +
airflow/jobs/scheduler_job.py | 4 +-
airflow/listeners/listener.py | 9 ++-
.../{api_connexion => listeners/spec}/__init__.py | 0
.../default.py => listeners/spec/dagrun.py} | 27 ++++----
.../listeners/spec/lifecycle.py | 33 +++++++---
.../listeners/{spec.py => spec/taskinstance.py} | 0
airflow/models/dagrun.py | 22 ++++++-
docs/apache-airflow/listeners.rst | 41 ++++++++----
docs/spelling_wordlist.txt | 3 +
tests/jobs/test_backfill_job.py | 29 +++++++++
tests/jobs/test_base_job.py | 25 ++++++++
tests/jobs/test_scheduler_job.py | 72 ++++++++++++++++++++++
.../{full_listener.py => class_listener.py} | 33 ++++++----
.../{full_listener.py => dag_listener.py} | 27 +++++---
tests/listeners/full_listener.py | 21 +++++++
.../{full_listener.py => lifecycle_listener.py} | 23 ++++---
tests/listeners/test_listeners.py | 53 ++++++++++++----
19 files changed, 344 insertions(+), 83 deletions(-)
copy airflow/{api_connexion => listeners/spec}/__init__.py (100%)
copy airflow/{api/auth/backend/default.py => listeners/spec/dagrun.py} (61%)
copy dev/breeze/src/airflow_breeze/utils/mark_image_as_refreshed.py => airflow/listeners/spec/lifecycle.py (59%)
rename airflow/listeners/{spec.py => spec/taskinstance.py} (100%)
copy tests/listeners/{full_listener.py => class_listener.py} (53%)
copy tests/listeners/{full_listener.py => dag_listener.py} (64%)
copy tests/listeners/{full_listener.py => lifecycle_listener.py} (70%)