This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from a06032e0f8e Update simple auth manager documentation to include token
API (#48454)
add fde5051eaca Move bases classes to `airflow.sdk.bases` (#48487)
No new revisions were added by this update.
Summary of changes:
airflow-core/src/airflow/decorators/base.py | 2 +-
airflow-core/src/airflow/decorators/condition.py | 2 +-
airflow-core/src/airflow/models/__init__.py | 11 +-
.../src/airflow/models/abstractoperator.py | 2 +-
airflow-core/src/airflow/models/baseoperator.py | 6 +-
.../src/airflow/models/baseoperatorlink.py | 2 +-
airflow-core/src/airflow/models/taskinstance.py | 2 +-
airflow-core/src/airflow/models/taskmap.py | 2 +-
airflow-core/src/airflow/models/xcom.py | 14 +-
airflow-core/src/airflow/sensors/base.py | 2 +-
.../airflow/serialization/serialized_objects.py | 2 +-
airflow-core/src/airflow/utils/task_group.py | 2 +-
.../core_api/routes/public/test_xcom.py | 3 +-
.../tests/unit/models/test_taskinstance.py | 2 +-
airflow-core/tests/unit/models/test_xcom.py | 3 +-
.../unit/serialization/test_dag_serialization.py | 4 +-
dev/mypy/plugin/outputs.py | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 2 +-
.../providers/common/compat/notifier/__init__.py | 4 +-
.../airflow/providers/common/io/xcom/backend.py | 2 +-
.../google/cloud/operators/dataproc_metastore.py | 1 -
.../openlineage/utils/selective_enable.py | 2 +-
.../unit/openlineage/extractors/test_manager.py | 2 +-
.../check_base_operator_partial_arguments.py | 2 +-
.../src/airflow/api => task-sdk}/__init__.py | 0
task-sdk/src/airflow/sdk/__init__.py | 20 +-
.../src/airflow/sdk/bases}/__init__.py | 0
.../sdk/{definitions => bases}/baseoperator.py | 0
.../airflow/sdk/{definitions => bases}/notifier.py | 0
.../baseoperatorlink.py => bases/operatorlink.py} | 0
.../sensors/base.py => bases/sensor.py} | 2 +-
.../airflow/sdk/{execution_time => bases}/xcom.py | 20 --
.../sdk/definitions/_internal/abstractoperator.py | 4 +-
.../airflow/sdk/definitions/_internal/mixins.py | 2 +-
.../src/airflow/sdk/definitions/_internal/node.py | 2 +-
task-sdk/src/airflow/sdk/definitions/context.py | 2 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 2 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 4 +-
.../airflow/sdk/definitions/sensors/__init__.py | 17 --
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 2 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 2 +-
.../src/airflow/sdk/execution_time/task_runner.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/xcom.py | 296 +--------------------
task-sdk/src/airflow/sdk/types.py | 2 +-
.../tests/task_sdk/bases}/__init__.py | 0
.../notifier/test_notifier.txt | 0
.../{definitions => bases}/test_baseoperator.py | 2 +-
.../{definitions => bases}/test_notifier.py | 2 +-
.../sensors/test_base.py => bases/test_sensor.py} | 2 +-
task-sdk/tests/task_sdk/dags/super_basic.py | 2 +-
task-sdk/tests/task_sdk/dags/super_basic_run.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_dag.py | 2 +-
.../task_sdk/definitions/test_mappedoperator.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_mixins.py | 2 +-
55 files changed, 77 insertions(+), 398 deletions(-)
copy {airflow-core/src/airflow/api => task-sdk}/__init__.py (100%)
copy {airflow-core/src/airflow/api =>
task-sdk/src/airflow/sdk/bases}/__init__.py (100%)
rename task-sdk/src/airflow/sdk/{definitions => bases}/baseoperator.py (100%)
rename task-sdk/src/airflow/sdk/{definitions => bases}/notifier.py (100%)
rename task-sdk/src/airflow/sdk/{definitions/baseoperatorlink.py =>
bases/operatorlink.py} (100%)
rename task-sdk/src/airflow/sdk/{definitions/sensors/base.py =>
bases/sensor.py} (99%)
copy task-sdk/src/airflow/sdk/{execution_time => bases}/xcom.py (94%)
delete mode 100644 task-sdk/src/airflow/sdk/definitions/sensors/__init__.py
copy {airflow-core/src/airflow/api =>
task-sdk/tests/task_sdk/bases}/__init__.py (100%)
rename task-sdk/tests/task_sdk/{definitions =>
bases}/notifier/test_notifier.txt (100%)
rename task-sdk/tests/task_sdk/{definitions => bases}/test_baseoperator.py
(99%)
rename task-sdk/tests/task_sdk/{definitions => bases}/test_notifier.py (98%)
rename task-sdk/tests/task_sdk/{definitions/sensors/test_base.py =>
bases/test_sensor.py} (99%)