This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 826fcc9832f Remove deprecated functionality from google provider
(#46235)
add 03c4966df41 AIP-72: Move DAG Params to Task SDK (#46176)
No new revisions were added by this update.
Summary of changes:
.../cli/commands/remote_commands/task_command.py | 2 +-
airflow/example_dags/example_params_trigger_ui.py | 2 +-
airflow/example_dags/example_params_ui_tutorial.py | 2 +-
airflow/models/__init__.py | 4 +-
airflow/models/param.py | 337 +--------------------
airflow/models/taskinstance.py | 2 +-
airflow/serialization/serialized_objects.py | 4 +-
airflow/utils/context.py | 2 +-
docs/apache-airflow/core-concepts/params.rst | 28 +-
docs/apache-airflow/public-airflow-interface.rst | 2 +-
.../edge/example_dags/integration_test.py | 2 +-
.../providers/edge/example_dags/win_notepad.py | 2 +-
.../providers/edge/example_dags/win_test.py | 2 +-
.../api_endpoints/test_dag_run_endpoint.py | 2 +-
task_sdk/src/airflow/sdk/__init__.py | 2 +
.../airflow/sdk/definitions/asset/decorators.py | 2 +-
.../src/airflow/sdk/definitions/baseoperator.py | 2 +-
task_sdk/src/airflow/sdk/definitions/dag.py | 2 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 2 +-
.../src/airflow/sdk/definitions}/param.py | 0
.../src/airflow/sdk/execution_time/task_runner.py | 13 +-
task_sdk/tests/conftest.py | 2 +
task_sdk/tests/definitions/test_dag.py | 2 +-
task_sdk/tests/definitions/test_mappedoperator.py | 2 +-
.../tests/definitions}/test_param.py | 131 ++------
task_sdk/tests/execution_time/conftest.py | 4 +
task_sdk/tests/execution_time/test_task_runner.py | 114 +++++++
tests/api_connexion/endpoints/test_dag_endpoint.py | 8 +-
.../endpoints/test_dag_run_endpoint.py | 2 +-
.../api_connexion/endpoints/test_task_endpoint.py | 10 +-
tests/api_connexion/schemas/test_dag_schema.py | 4 +-
tests/api_connexion/schemas/test_task_schema.py | 2 +-
.../core_api/routes/public/test_dag_run.py | 2 +-
.../core_api/routes/public/test_dags.py | 2 +-
.../core_api/routes/public/test_tasks.py | 10 +-
tests/dags/test_invalid_param.py | 2 +-
tests/dags/test_invalid_param2.py | 2 +-
tests/dags/test_invalid_param3.py | 2 +-
tests/dags/test_invalid_param4.py | 2 +-
tests/dags/test_valid_param.py | 2 +-
tests/dags/test_valid_param2.py | 2 +-
tests/models/test_dag.py | 4 +-
tests/models/test_param.py | 267 +---------------
tests/models/test_taskinstance.py | 2 +-
.../serialization/serializers/test_serializers.py | 2 +-
tests/serialization/test_dag_serialization.py | 2 +-
tests/serialization/test_serialized_objects.py | 2 +-
tests/www/views/test_views_trigger_dag.py | 2 +-
48 files changed, 227 insertions(+), 777 deletions(-)
copy {airflow/models => task_sdk/src/airflow/sdk/definitions}/param.py (100%)
copy {tests/models => task_sdk/tests/definitions}/test_param.py (80%)
