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 ee976100eb3 Bump min fastapi to 0.115.0 to support query param models
(#48479)
add 347c98cd8c2 Move `BaseSensorOperator` to TaskSDK definitions (#48244)
No new revisions were added by this update.
Summary of changes:
.../execution_api/routes/task_reschedules.py | 7 +-
airflow-core/src/airflow/models/baseoperator.py | 10 -
airflow-core/src/airflow/models/taskinstance.py | 10 +
airflow-core/src/airflow/sensors/README.md | 24 -
airflow-core/src/airflow/sensors/__init__.py | 1 +
airflow-core/src/airflow/sensors/base.py | 383 +-----
.../versions/head/test_task_instances.py | 2 +-
airflow-core/tests/unit/decorators/test_sensor.py | 169 +--
.../tests/unit/models/test_baseoperator.py | 17 -
.../tests/unit/models/test_taskinstance.py | 87 +-
airflow-core/tests/unit/sensors/test_base.py | 1388 --------------------
.../unit/sensors/test_external_task_sensor.py | 8 +-
airflow-core/tests/unit/sensors/test_filesystem.py | 24 +-
.../unit/serialization/test_dag_serialization.py | 17 +-
devel-common/src/tests_common/pytest_plugin.py | 2 +-
.../providers/amazon/aws/sensors/step_function.py | 3 +-
.../tests/unit/arangodb/sensors/test_arangodb.py | 2 +-
.../sql/tests/unit/common/sql/sensors/test_sql.py | 12 +-
.../sensors/test_databricks_partition.py | 5 -
.../unit/databricks/sensors/test_databricks_sql.py | 5 -
.../tests/unit/github/sensors/test_github.py | 2 +-
.../google/cloud/links/cloud_storage_transfer.py | 4 +-
.../operators/cloud_storage_transfer_service.py | 3 -
.../sensors/cloud_storage_transfer_service.py | 7 +-
.../http/tests/unit/http/sensors/test_http.py | 21 +-
.../unit/sftp/decorators/sensors/test_sftp.py | 33 +-
.../providers/standard/sensors/external_task.py | 6 +-
.../tests/unit/standard/sensors/test_time_delta.py | 16 +-
.../tests/unit/standard/sensors/test_weekday.py | 6 +-
task-sdk/src/airflow/sdk/__init__.py | 3 +
.../src/airflow/sdk/definitions/baseoperator.py | 20 +
.../airflow/sdk/definitions/sensors}/__init__.py | 0
.../src/airflow/sdk/definitions}/sensors/base.py | 19 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 4 +-
.../src/airflow/sdk/execution_time/task_runner.py | 10 +-
task-sdk/tests/conftest.py | 162 +--
.../task_sdk/definitions/sensors}/__init__.py | 0
.../task_sdk/definitions/sensors/test_base.py | 685 ++++++++++
.../task_sdk/execution_time/test_task_runner.py | 2 +-
39 files changed, 870 insertions(+), 2309 deletions(-)
delete mode 100644 airflow-core/src/airflow/sensors/README.md
delete mode 100644 airflow-core/tests/unit/sensors/test_base.py
copy {airflow-core/src/airflow/api/common =>
task-sdk/src/airflow/sdk/definitions/sensors}/__init__.py (100%)
copy {airflow-core/src/airflow =>
task-sdk/src/airflow/sdk/definitions}/sensors/base.py (95%)
copy {airflow-core/src/airflow/api =>
task-sdk/tests/task_sdk/definitions/sensors}/__init__.py (100%)
create mode 100644 task-sdk/tests/task_sdk/definitions/sensors/test_base.py
