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 2023/02/03 14:40:13 UTC

[airflow] branch main updated (edc2e0b118 -> 624520db47)

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 edc2e0b118 Write action log to DB when DAG run is trigged via API (#28998)
     add 624520db47 listener: simplify API by replacing SQLAlchemy event-listening by direct calls (#29289)

No new revisions were added by this update.

Summary of changes:
 airflow/jobs/local_task_job.py                     |  9 ---
 airflow/listeners/events.py                        | 85 ----------------------
 airflow/models/taskinstance.py                     | 15 ++++
 .../{test_missing_owner.py => test_failing.py}     | 21 +++---
 tests/listeners/class_listener.py                  |  4 +
 tests/listeners/empty_listener.py                  |  4 +
 tests/listeners/file_write_listener.py             | 16 ++++
 tests/listeners/partial_listener.py                |  4 +
 tests/listeners/test_listeners.py                  | 38 +++++++---
 tests/listeners/throwing_listener.py               |  4 +
 .../task/task_runner/test_standard_task_runner.py  | 49 ++++++++++++-
 11 files changed, 131 insertions(+), 118 deletions(-)
 delete mode 100644 airflow/listeners/events.py
 copy tests/dags/{test_missing_owner.py => test_failing.py} (71%)