This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 13c28dc1f8b Bump uv to 0.7.20 (#53207)
add 379c478a010 Remove direct scheduler BaseOperator refs (#52234)
No new revisions were added by this update.
Summary of changes:
airflow-core/src/airflow/api/common/mark_tasks.py | 2 +-
.../core_api/routes/public/extra_links.py | 11 +-
.../api_fastapi/core_api/services/ui/grid.py | 37 +-
.../src/airflow/cli/commands/task_command.py | 2 +-
.../airflow/example_dags/example_dag_decorator.py | 3 +-
...amic_task_mapping_with_no_taskflow_operators.py | 3 +-
.../src/airflow/example_dags/example_skip_dag.py | 3 +-
airflow-core/src/airflow/models/__init__.py | 14 +-
airflow-core/src/airflow/models/baseoperator.py | 504 ---------------------
airflow-core/src/airflow/models/dag.py | 8 +-
airflow-core/src/airflow/models/dagrun.py | 37 +-
airflow-core/src/airflow/models/mappedoperator.py | 143 ++++--
airflow-core/src/airflow/models/operator.py | 26 --
.../src/airflow/models/renderedtifields.py | 6 +-
airflow-core/src/airflow/models/taskinstance.py | 87 ++--
airflow-core/src/airflow/models/taskmap.py | 7 +-
airflow-core/src/airflow/policies.py | 2 +-
.../airflow/serialization/serialized_objects.py | 344 +++++++++++---
.../ti_deps/deps/mapped_task_upstream_dep.py | 3 +-
.../src/airflow/ti_deps/deps/prev_dagrun_dep.py | 8 +-
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 4 +-
airflow-core/src/airflow/utils/dag_edges.py | 3 +-
airflow-core/src/airflow/utils/dot_renderer.py | 31 +-
airflow-core/src/airflow/utils/task_group.py | 35 +-
.../tests/unit/cluster_policies/__init__.py | 2 +-
airflow-core/tests/unit/dags/test_dag_warnings.py | 3 +-
.../tests/unit/models/test_baseoperator.py | 279 ------------
airflow-core/tests/unit/models/test_dagbag.py | 26 +-
airflow-core/tests/unit/models/test_dagrun.py | 81 +++-
.../unit/serialization/test_dag_serialization.py | 6 +-
.../unit/serialization/test_serialized_objects.py | 24 +
devel-common/src/tests_common/test_utils/compat.py | 2 +-
.../openlineage/utils/selective_enable.py | 12 +-
.../providers/opensearch/log/os_task_handler.py | 3 +-
.../airflow/providers/standard/utils/skipmixin.py | 7 +-
.../check_base_operator_partial_arguments.py | 35 +-
task-sdk/src/airflow/sdk/bases/operator.py | 132 +++---
.../sdk/definitions/_internal/abstractoperator.py | 85 ----
.../airflow/sdk/definitions/_internal/mixins.py | 6 +-
.../src/airflow/sdk/definitions/_internal/node.py | 88 +++-
task-sdk/src/airflow/sdk/definitions/dag.py | 20 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 64 ++-
task-sdk/src/airflow/sdk/definitions/param.py | 13 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 12 +-
task-sdk/tests/task_sdk/bases/test_operator.py | 82 +++-
45 files changed, 988 insertions(+), 1317 deletions(-)
delete mode 100644 airflow-core/src/airflow/models/baseoperator.py
delete mode 100644 airflow-core/src/airflow/models/operator.py
delete mode 100644 airflow-core/tests/unit/models/test_baseoperator.py
