This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a change to branch remove-legacy-ui
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 31e81202732 Stop testing api_connexion
add 4833b53705a Refactor result_processor and event_handler signatures in
MSGraphAsyncOperator (#46637)
add 3e6c6a109ea Fix wrong operator name in doc string of @task.kubernetes
(#46873)
add 3e13c2fb35c Remove deprecated get_link signature support (#46415)
add 6a7203a2da3 Use run_id to implement ti clear in API when given (#46883)
add d1bf9c5dd19 Fix MultipleCronTriggerTimetable deserialization (#46886)
add f0abca1e8e7 Import the right BaseOperator in baseoperatorlinks (#46895)
add 13c3e76af4f Minor DAG processor logging cleanup (#46878)
add ae5afd97dd6 AIP-81 Include CLI Token Expiration Time API Configuration
and Integrate New Config in SimpleAuthManager (#46839)
add bb560528035 Implement dag version selector for source code. (#46885)
add 711d1fdc0e0 Enable accessing Variables from the top level of the DAG
files (#46869)
add 0adb5ad1cbe Fix run/task table links (#46901)
add 319cf3051b7 Remove 2.8 version check from CeleryExecutor CLI (#46910)
add c505b240bce AIP-84 Asset dependencies graph node filtering (#46890)
add 43e3f6aa4cb Slow down DAG processor refreshing bundles (#46870)
add d903d76be3c Validation logic for the payload moved to the Serializer
for trigger_dag_run (#46882)
add 56e083f1455 AIP-72: Swap KubernetesExecutor to use taskSDK for
execution (#46860)
add 8765fc990a7 Remove unused discovery using sources from Providers
Manager (#46840)
add 851b6c36bfb Clean up some straggling "standalone" DAG processor
references (#46909)
add b95990b3267 Allow schedule args in asset decorator (#46851)
add ee68ddf605c Refactor deferrable mode for BeamRunPythonPipelineOperator
and BeamRunJavaPipelineOperator (#46678)
add 7b123cd8198 Add link to latest dagrun in dags list. (#46907)
add f63652eca14 Make rendered_map_index default to map_index (#46918)
add d983b6ac946 Fix some warnings in React components (#46919)
add 9877491c159 Add a note `airflow users` command is available when FAB
auth-manager is enabled (#46862)
add dddcebc508c Give each tmux pane in `start-airflow` a title to make it
clear what is running (#46931)
add a29c840d938 Allow check_response to be defined in extra_options of
HTTP connection (#45451)
add c141383d5bf fix: api_version on on_kill method (#46833)
add ae2c59adbea Remove orphaned celery_command file (#46879)
add 3f548a01531 Bump trove-classifiers from 2025.1.15.22 to 2025.2.18.16
(#46903)
add b99cb7ce108 Create operators for working with Topics for GCP Apache
Kafka (#46865)
add 91d0fcbb905 Merge remote-tracking branch 'upstream/main' into
remove-legacy-ui
No new revisions were added by this update.
Summary of changes:
.../api_connexion/schemas/task_instance_schema.py | 2 +-
airflow/api_fastapi/app.py | 2 +-
airflow/api_fastapi/core_api/datamodels/dag_run.py | 35 ++
.../api_fastapi/core_api/openapi/v1-generated.yaml | 21 ++
.../api_fastapi/core_api/routes/public/dag_run.py | 37 +--
.../core_api/routes/public/task_instances.py | 6 +-
.../api_fastapi/core_api/routes/ui/dependencies.py | 20 +-
.../core_api/services/ui/dependencies.py | 78 +++++
airflow/api_fastapi/execution_api/app.py | 42 ++-
.../auth/managers/simple/openapi/v1-generated.yaml | 38 +++
.../managers/simple/{router => routes}/__init__.py | 0
.../managers/simple/{router => routes}/login.py | 48 +--
.../managers/simple/services}/__init__.py | 0
airflow/auth/managers/simple/services/login.py | 74 +++++
.../auth/managers/simple/simple_auth_manager.py | 2 +-
airflow/cli/cli_config.py | 2 +-
.../cli/commands/local_commands/celery_command.py | 245 --------------
airflow/config_templates/config.yml | 20 ++
airflow/config_templates/unit_tests.cfg | 1 +
airflow/dag_processing/manager.py | 31 +-
airflow/dag_processing/processor.py | 64 +++-
airflow/models/baseoperatorlink.py | 3 -
airflow/models/dag.py | 2 +-
airflow/models/taskinstance.py | 14 +-
airflow/models/taskinstancehistory.py | 2 +-
airflow/models/variable.py | 24 ++
airflow/providers_manager.py | 111 +------
airflow/serialization/serialized_objects.py | 8 +-
airflow/timetables/trigger.py | 2 +-
airflow/ui/openapi-gen/queries/common.ts | 12 +-
airflow/ui/openapi-gen/queries/prefetch.ts | 15 +-
airflow/ui/openapi-gen/queries/queries.ts | 11 +-
airflow/ui/openapi-gen/queries/suspense.ts | 11 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 12 +-
airflow/ui/openapi-gen/requests/types.gen.ts | 13 +
airflow/ui/src/components/RenderedJsonField.tsx | 2 +-
.../ui/src/components/SearchDags/SearchDags.tsx | 1 +
airflow/ui/src/pages/Dag/Code/Code.tsx | 86 ++++-
airflow/ui/src/pages/DagRuns.tsx | 5 -
airflow/ui/src/pages/DagsList/DagsList.tsx | 18 +-
airflow/ui/src/pages/Providers.tsx | 2 +-
airflow/ui/src/pages/TaskInstance/Details.tsx | 6 +-
airflow/ui/src/pages/TaskInstances.tsx | 23 +-
contributing-docs/03_contributors_quick_start.rst | 2 +
.../contributors_quick_start_gitpod.rst | 3 +
docs/apache-airflow/core-concepts/overview.rst | 4 +
docs/apache-airflow/security/security_model.rst | 24 +-
docs/apache-airflow/start.rst | 3 +
generated/provider_dependencies.json | 2 +-
hatch_build.py | 1 +
kubernetes_tests/test_kubernetes_executor.py | 6 +
newsfragments/46415.significant.rst | 25 ++
.../airflow/providers/airbyte/operators/airbyte.py | 2 +-
.../tests/unit/airbyte/operators/test_airbyte.py | 17 +
.../airflow/providers/apache/beam/hooks/beam.py | 22 +-
.../providers/apache/beam/operators/beam.py | 295 ++++++++---------
.../airflow/providers/apache/beam/triggers/beam.py | 104 +-----
.../beam/tests/unit/apache/beam/hooks/test_beam.py | 32 +-
.../tests/unit/apache/beam/operators/test_beam.py | 18 +-
.../tests/unit/apache/beam/triggers/test_beam.py | 49 ---
providers/apache/livy/README.rst | 2 +-
providers/apache/livy/pyproject.toml | 2 +-
.../providers/apache/livy/get_provider_info.py | 2 +-
.../airflow/providers/apache/livy/hooks/livy.py | 15 +-
.../providers/celery/executors/celery_executor.py | 7 +-
.../src/airflow/providers/celery/version_compat.py | 1 -
.../cncf/kubernetes/decorators/kubernetes.py | 2 +-
.../kubernetes/executors/kubernetes_executor.py | 33 +-
.../executors/kubernetes_executor_utils.py | 21 +-
.../providers/cncf/kubernetes/pod_generator.py | 60 +++-
.../unit/cncf/kubernetes/test_pod_generator.py | 62 ++++
.../google/docs/operators/cloud/managed_kafka.rst | 48 +++
providers/google/provider.yaml | 1 +
.../providers/google/cloud/hooks/managed_kafka.py | 198 ++++++++++-
.../providers/google/cloud/links/managed_kafka.py | 29 ++
.../google/cloud/operators/managed_kafka.py | 337 +++++++++++++++++++
.../airflow/providers/google/get_provider_info.py | 1 +
.../cloud/dataflow/example_dataflow_native_java.py | 34 +-
.../dataflow/example_dataflow_native_python.py | 32 +-
...a_cluster.py => example_managed_kafka_topic.py} | 100 ++++--
.../unit/google/cloud/hooks/test_managed_kafka.py | 246 ++++++++++++++
.../unit/google/cloud/links/test_managed_kafka.py | 38 +++
.../google/cloud/operators/test_managed_kafka.py | 172 ++++++++++
providers/http/README.rst | 6 +-
providers/http/docs/index.rst | 2 +-
providers/http/provider.yaml | 1 +
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../airflow/providers/http/get_provider_info.py | 1 +
.../http/src/airflow/providers/http/hooks/http.py | 127 ++++----
providers/http/tests/unit/http/hooks/test_http.py | 150 ++++++---
.../http/tests/unit/http/sensors/test_http.py | 18 +-
.../providers/microsoft/azure/hooks/msgraph.py | 2 +-
.../providers/microsoft/azure/operators/msgraph.py | 53 ++-
.../providers/microsoft/azure/sensors/msgraph.py | 21 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 21 ++
.../unit/microsoft/azure/operators/test_msgraph.py | 99 +++++-
.../unit/microsoft/azure/sensors/test_msgraph.py | 47 ++-
pyproject.toml | 2 +-
.../ci/pre_commit/check_ti_vs_tis_attributes.py | 1 +
scripts/cov/cli_coverage.py | 1 -
scripts/in_container/bin/run_tmux | 10 +
task_sdk/src/airflow/sdk/__init__.py | 2 +
task_sdk/src/airflow/sdk/api/client.py | 4 +-
.../airflow/sdk/definitions/asset/decorators.py | 7 +-
task_sdk/src/airflow/sdk/definitions/variable.py | 13 +
.../airflow/sdk/execution_time/execute_workload.py | 89 +++++
.../src/airflow/sdk/execution_time/task_runner.py | 1 -
.../tests/definitions/test_asset_decorators.py | 2 +
tests/always/test_providers_manager.py | 7 -
.../core_api/routes/public/test_providers.py | 2 -
.../core_api/routes/public/test_task_instances.py | 54 ++-
.../core_api/routes/ui/test_dependencies.py | 109 ++++++-
tests/api_fastapi/test_app.py | 6 +-
.../managers/simple/{test_user.py => conftest.py} | 26 +-
.../auth/managers/simple/routes}/__init__.py | 0
tests/auth/managers/simple/routes/test_login.py | 82 +++++
.../auth/managers/simple/services}/__init__.py | 0
tests/auth/managers/simple/services/test_login.py | 81 +++++
.../managers/simple/test_simple_auth_manager.py | 21 --
tests/auth/managers/simple/test_user.py | 21 +-
.../commands/local_commands/test_celery_command.py | 361 ---------------------
tests/dag_processing/test_manager.py | 30 ++
tests/dag_processing/test_processor.py | 87 +++--
.../cli/commands/test_celery_command.py | 6 +-
tests/models/test_taskinstance.py | 2 +-
tests/timetables/test_trigger_timetable.py | 25 ++
127 files changed, 3188 insertions(+), 1623 deletions(-)
create mode 100644 airflow/api_fastapi/core_api/services/ui/dependencies.py
rename airflow/auth/managers/simple/{router => routes}/__init__.py (100%)
rename airflow/auth/managers/simple/{router => routes}/login.py (51%)
copy airflow/{api_connexion => auth/managers/simple/services}/__init__.py
(100%)
create mode 100644 airflow/auth/managers/simple/services/login.py
delete mode 100644 airflow/cli/commands/local_commands/celery_command.py
create mode 100644 newsfragments/46415.significant.rst
copy
providers/google/tests/system/google/cloud/managed_kafka/{example_managed_kafka_cluster.py
=> example_managed_kafka_topic.py} (57%)
create mode 100644 task_sdk/src/airflow/sdk/execution_time/execute_workload.py
copy tests/auth/managers/simple/{test_user.py => conftest.py} (70%)
copy {airflow/api_connexion => tests/auth/managers/simple/routes}/__init__.py
(100%)
create mode 100644 tests/auth/managers/simple/routes/test_login.py
copy {airflow/api_connexion =>
tests/auth/managers/simple/services}/__init__.py (100%)
create mode 100644 tests/auth/managers/simple/services/test_login.py
delete mode 100644 tests/cli/commands/local_commands/test_celery_command.py
