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 cb40ffb38d8 Add clear dag run to UI (#45039)
add 8774f28d76b Swap Dag Parsing to use the TaskSDK machinery. (#44972)
No new revisions were added by this update.
Summary of changes:
airflow/callbacks/callback_requests.py | 105 +--
.../local_commands/dag_processor_command.py | 8 +-
airflow/dag_processing/collection.py | 84 +-
airflow/dag_processing/manager.py | 860 +++++++++------------
airflow/dag_processing/processor.py | 723 +++++------------
airflow/jobs/dag_processor_job_runner.py | 6 +-
airflow/jobs/scheduler_job_runner.py | 6 +-
airflow/models/dag.py | 31 +-
airflow/models/dagbag.py | 2 +-
airflow/models/dagcode.py | 10 +-
airflow/models/serialized_dag.py | 15 +-
airflow/serialization/serialized_objects.py | 92 ++-
airflow/triggers/base.py | 3 +-
.../src/airflow/sdk/execution_time/supervisor.py | 43 +-
.../src/airflow/sdk/execution_time/task_runner.py | 2 +-
task_sdk/src/airflow/sdk/log.py | 12 +-
tests/callbacks/test_callback_requests.py | 51 +-
tests/dag_processing/test_collection.py | 28 +-
tests/dag_processing/test_manager.py | 578 ++++----------
tests/dag_processing/test_processor.py | 358 ++++-----
tests/executors/test_base_executor.py | 4 +-
tests/jobs/test_scheduler_job.py | 23 +-
tests/listeners/dag_import_error_listener.py | 8 +-
tests/listeners/test_dag_import_error_listener.py | 163 ----
tests/models/test_dagcode.py | 2 +-
25 files changed, 1131 insertions(+), 2086 deletions(-)
delete mode 100644 tests/listeners/test_dag_import_error_listener.py
