You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by po...@apache.org on 2022/02/22 15:36:01 UTC

[airflow] branch main updated (15a72d0 -> 2a615ab)

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git.


    from 15a72d0  Fix failing tests on main due to merging incompatible changes (#21733)
     add 2a615ab  Introduce 'Callbacks Sink' classes for sending callbacks (#21301)

No new revisions were added by this update.

Summary of changes:
 .../timetables => airflow/callbacks}/__init__.py   |  0
 .../base_callback_sink.py}                         | 12 ++--
 airflow/{utils => callbacks}/callback_requests.py  |  7 +-
 airflow/callbacks/pipe_callback_sink.py            | 47 +++++++++++++
 airflow/dag_processing/manager.py                  | 34 ++--------
 airflow/dag_processing/processor.py                | 12 ++--
 airflow/executors/base_executor.py                 | 14 ++++
 airflow/jobs/scheduler_job.py                      | 23 ++++---
 airflow/models/dagrun.py                           | 13 ++--
 tests/dag_processing/test_manager.py               |  2 +-
 tests/dag_processing/test_processor.py             |  2 +-
 tests/jobs/test_scheduler_job.py                   | 76 +++++++++-------------
 tests/models/test_dagrun.py                        |  2 +-
 tests/test_utils/mock_executor.py                  |  2 +
 14 files changed, 135 insertions(+), 111 deletions(-)
 copy {tests/timetables => airflow/callbacks}/__init__.py (100%)
 copy airflow/{migrations/db_types.pyi => callbacks/base_callback_sink.py} (74%)
 rename airflow/{utils => callbacks}/callback_requests.py (95%)
 create mode 100644 airflow/callbacks/pipe_callback_sink.py