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/03/08 13:55:22 UTC
[airflow] branch main updated (4014194 -> 5ace37a)
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 4014194 Add new options to DatabricksCopyIntoOperator (#22076)
add 5ace37a Store callbacks in database if standalone_dag_processor config is True. (#21731)
No new revisions were added by this update.
Summary of changes:
airflow/callbacks/callback_requests.py | 30 ++++-
..._callback_sink.py => database_callback_sink.py} | 15 ++-
airflow/config_templates/config.yml | 16 +++
airflow/config_templates/default_airflow.cfg | 8 ++
airflow/dag_processing/manager.py | 32 ++++-
airflow/executors/celery_kubernetes_executor.py | 2 +-
airflow/executors/local_kubernetes_executor.py | 2 +-
airflow/jobs/scheduler_job.py | 88 +++++++------
... => c97c2ab6aa23_add_callback_request_table.py} | 33 ++---
airflow/models/__init__.py | 2 +
airflow/models/db_callback_request.py | 52 ++++++++
airflow/models/taskinstance.py | 97 +++++++++++---
airflow/utils/db_cleanup.py | 2 +
docs/apache-airflow/migrations-ref.rst | 4 +-
tests/{timetables => callbacks}/__init__.py | 0
tests/callbacks/test_callback_requests.py | 70 +++++++++++
tests/dag_processing/test_manager.py | 139 ++++++++++++++++++++-
tests/dag_processing/test_processor.py | 10 +-
tests/executors/test_celery_executor.py | 4 +-
tests/jobs/test_scheduler_job.py | 28 ++++-
tests/test_utils/db.py | 6 +
21 files changed, 543 insertions(+), 97 deletions(-)
copy airflow/callbacks/{base_callback_sink.py => database_callback_sink.py} (63%)
copy airflow/migrations/versions/{c381b21cb7e4_add_session_table_to_db.py => c97c2ab6aa23_add_callback_request_table.py} (57%)
create mode 100644 airflow/models/db_callback_request.py
copy tests/{timetables => callbacks}/__init__.py (100%)
create mode 100644 tests/callbacks/test_callback_requests.py