This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch generate-task-jwt-tokens
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 1c9548caf95 Add compat for Airflow 2.10 for Edge Provider
omit 29969ddf334 Add JWT validation and generation machinery for the Task
Execution API to use
add 02a4bbf0872 Make local venv and uv recommended choice for quick-start
(#47474)
add 5484b7b6244 Bugfix typing after google-ads release 26.0.0 release
(#47471)
add 073353b57b3 Add optional configuration for startupProbe
initialDelaySeconds (#47094)
add 58c6a495651 Remove the old `task run` commands and LocalTaskJob
(#47453)
add aa071608923 AIP-72: Moving BaseOperatorLink to task sdk (#47008)
add afcfb86106b chore: Update description of `execution_timeout` in
OpenLineage provider.yaml (#47448)
add ab3a1869c57 AIP-84 | Add Auth for Config (#47208)
add dc7005ce145 Docs: Fix typo in unit_tests docs (#47476)
add eb7735583ae AIP-84 | Add Auth for Extra Link (#47251)
add c847bfb3f8d Change style for task logger and allow filtering by source
(#47469)
add cd78078e4e4 Move asset evaluation logic out of SDK (#47484)
add 85c3fbac2df Remove regexp from dag.partial_subset method and update
callers (#47360)
add 092cc57f025 Get rid of google-re2 as dependency (#47493)
add 2a63b4702fd Make command for replacing newlines with literals `\n` in
`SSHOperator`connection MacOs/Linux compatible (#47491)
add 58f4ce07b12 AIP-38 Add modelName to Providers and Plugins table
(#47506)
add 506ab621f9c Update pgbouncer to 1.23.1 and pgbouncer_exporter to
0.18.0 in helm chart (#47416)
add 1d70f952939 Add custom AWS Region support for STS endpoint to
`hashicorp` provider (#47495)
add 122b20bb0fe fix: don't use blocking property access for async purposes
(#47326)
add a4388ac4b3c Remove remaining pieces of k8s exec specific UI pages
(#47422)
add 7bd8ea68215 Cleanup leftovers from api connexion (#47490)
add b563e35a7a7 Add skipimport check for aiobotocore module in aws trigger
tests (#47512)
add 0ec4aebbde7 Bump axios from 1.7.7 to 1.8.2 in /airflow/ui (#47513)
add 97bd5c70cb2 Remove unused code in Fab provider (#47510)
add f0de8a9c97e Print scheduler call stack when SIGUSR2 received (#47311)
add 06be13bc517 Clean up simple auth and fab provider package json files
(#47516)
add b8f2964d0fb Fix aws trigger tests, use get_async_conn for mock object
(#47515)
add 5b36dd9dcde Re-add UI dist files to published docker (#47520)
add 8cc9f1fca93 Relocate airflow.auth to airflow.api_fastapi.auth (#47492)
add 2a39959f6f4 Rework Params UI Tutorial DAG (#47265)
add b3bccab3a7b Feat: Add username, password to Pinot Connection (#46826)
add 2ea7aed7550 Fix xcom_pull for task_ids=None (#47407)
add 687b86741ec Add other executor tests to K8s tests (#47472)
add efe4bed2469 Bump axios in /airflow/api_fastapi/auth/managers/simple/ui
(#47524)
add bd47fd088dd Bump esbuild, vite and vitest (#47525)
add 599b3ab85de Use localhost instead of 127.0.0.1 in breeze visuals
(#47534)
add dc02968418d Only grab DAGs from bundles being parsed in stale DAG
cleanup (#47519)
add 6b69eb7b9aa Relocate SmoothOperator to standard provider and add tests
(#47530)
add d5bba0ba48f AƱadir Idrica a INTHEWILD.md (#47536)
add cffbb58bb4c Fix Breeze K8s: Patch ConfigMap [api/base_url] with
Port-Forwarded Host Port (#47544)
add 686ada11081 Fix providers redirects.txt github reference link (#47540)
add d5bfbc090ab Adding .vite inside airflow/ui to gitignore (#47547)
add b5e9013d11c Avoid Title underline too short (#47546)
add 492ecfe5c03 Prepare docs for Mar 1st wave of providers (#47545)
add 4bc7ffb86df feat: allow to set task/dag labels for
`DataprocCreateBatchOperator` (#46781)
add 58142bd45f6 Remove cncf.kubernetes and common.compat from chicken/egg
providers list (#47517)
add e35cf2febb3 Scheduler shouldn't crash when 'executor_config' is passed
for executors using task SDK (#47548)
add 2dcb15f3d1f Add Dataflow Apache Beam Java streaming system test
(#47209)
add 7d29a786407 Re-introduce (and correctly call) the ExecutorSafeguard in
TaskSDK (#47523)
add 1e2660b3fca AIP 84 - Add auth for asset alias (#47241)
add b2c646af408 feat: Adjust DBT OpenLineage to Airflow 3 and improve
logging (#47500)
add 7f7c7a7b459 Fix comment typo in PythonOperator (#47558)
add e3fe06382df Removed accidentally added 'echo' in precommit (#47560)
add a81c1440b10 Fix the `compile-ui-assets-dev` manual pre-commit stage
(#47570)
add cf0349247b6 Skip populating ti if task is deleted (#47526)
add a26ea38027d feat(AIP-84): Add Auth for ui assets (#47485)
add febd23392c0 Update documentation priority weight (#47529)
add cc70fce5bed AIP-38 Move token handling to axios interceptor (#47562)
add 8870d764176 Fix static checks (#47578)
add df8df68466e Implement `simple_auth_manager_all_admins` in simple auth
manager with new auth flow (#47514)
add cc471f96c14 Move `airflow/api_fastapi/auth/managers/utils/fab` to FAB
provider (#47571)
add dc81593c408 Add `logout` method in auth manager interface (#47573)
add f55db378ffe Update docs to reflect auth manager move to `api_fastapi`
(#47575)
add eb18f87f091 Stop trying to reconfigure the ORM in the OpenLineage
workers (#47580)
add 74d7625de13 feat(AIP-84): Add auth for ui config (#47487)
add 7661659cfc5 Fix issue with bad log debug merge of context vars (#47589)
add 802cb87fae4 Replace TaskInstanceNote composite primary key with TI.id
(#47376)
add 637525cf9a2 AIP-84 Add Auth to plugins (#47504)
add 2b1c2758f41 Add name and dag_id to asset decorators (#47596)
add 45d040e01c9 AIP-84 Add Auth to providers (#47505)
add 3a9cce97fdb AIP-84 Adding logging actions (#47556)
add a96ec64083c FAB login. Fix asset URLs and missing alert (#47586)
add 9c4ec2097cd Update to latest uv version (#47605)
add cee31a8a0ca Fix static check (#47302)
add 41a8a9a4c69 AIP-84 | Add Auth for Dags (#47433)
add 5c77768bc14 AIP-84 | Add Auth for Job (#47271)
add 9d714c83cab Remove default_view property from DAG class and model
(#47616)
add bfd1881fa0c AIP-84 Add safe url helper method (#47577)
add 47963530deb Add asset event create button to asset list. (#47611)
add 04552094f51 Delete paused query parameter when filter value is all.
(#47607)
add 245d26dac17 Use a single http tag to report the server's location to
front end, not two (#47572)
add e908134c394 Add JWT validation and generation machinery for the Task
Execution API to use
add 57cc5b5d839 Add compat for Airflow 2.10 for Edge Provider
add 9ea089e049c Rename `get_jwt_token` to `generate_jwt`
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1c9548caf95)
\
N -- N -- N refs/heads/generate-task-jwt-tokens (9ea089e049c)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.dockerignore | 4 +
.github/CODEOWNERS | 2 -
.github/actions/install-pre-commit/action.yml | 2 +-
.github/boring-cyborg.yml | 1 -
.github/workflows/basic-tests.yml | 12 +-
.gitignore | 1 +
.pre-commit-config.yaml | 81 +-
Dockerfile | 2 +-
Dockerfile.ci | 2 +-
INTHEWILD.md | 1 +
LICENSE | 1 -
airflow/api_connexion/schemas/dag_schema.py | 86 -
airflow/api_fastapi/app.py | 13 +-
airflow/{ => api_fastapi}/auth/__init__.py | 0
.../{ => api_fastapi}/auth/managers/__init__.py | 0
.../auth/managers/base_auth_manager.py | 54 +-
.../auth/managers/models/__init__.py | 0
.../auth/managers/models/base_user.py | 0
.../auth/managers/models/batch_apis.py | 4 +-
.../auth/managers/models/resource_details.py | 7 +
.../auth/managers/simple/__init__.py | 0
.../auth/managers/simple/datamodels/__init__.py | 0
.../auth/managers/simple/datamodels/login.py | 0
.../auth/managers/simple/openapi/__init__.py | 0
.../auth/managers/simple/openapi/v1-generated.yaml | 19 +
.../auth/managers/simple/routes/__init__.py | 0
.../auth/managers/simple/routes/login.py | 32 +-
.../auth/managers/simple/services}/__init__.py | 0
.../auth/managers/simple/services/login.py | 8 +-
.../auth/managers/simple/simple_auth_manager.py | 43 +-
.../auth/managers/simple/ui/dev/index.html | 0
.../auth/managers/simple/ui/index.html | 0
.../simple/ui/openapi-gen/queries/common.ts | 0
.../simple/ui/openapi-gen/queries/index.ts | 0
.../ui/openapi-gen/queries/infiniteQueries.ts | 0
.../simple/ui/openapi-gen/queries/prefetch.ts | 0
.../simple/ui/openapi-gen/queries/queries.ts | 0
.../simple/ui/openapi-gen/queries/suspense.ts | 0
.../ui/openapi-gen/requests/core/ApiError.ts | 0
.../openapi-gen/requests/core/ApiRequestOptions.ts | 0
.../ui/openapi-gen/requests/core/ApiResult.ts | 0
.../openapi-gen/requests/core/CancelablePromise.ts | 0
.../simple/ui/openapi-gen/requests/core/OpenAPI.ts | 0
.../simple/ui/openapi-gen/requests/core/request.ts | 0
.../simple/ui/openapi-gen/requests/index.ts | 0
.../simple/ui/openapi-gen/requests/schemas.gen.ts | 0
.../simple/ui/openapi-gen/requests/services.gen.ts | 0
.../simple/ui/openapi-gen/requests/types.gen.ts | 0
.../auth/managers/simple/ui/package-lock.json | 560 +-
.../auth/managers/simple/ui/package.json | 6 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 860 +-
.../managers/simple/ui/src/login/Login.test.tsx | 0
.../auth/managers/simple/ui/src/login/Login.tsx | 0
.../managers/simple/ui/src/login/LoginForm.tsx | 0
.../auth/managers/simple/ui/src/main.tsx | 0
.../simple/ui/src/queries/useCreateToken.ts | 0
.../auth/managers/simple/ui/src/queryClient.ts | 0
.../auth/managers/simple/ui/src/router.tsx | 2 +-
.../auth/managers/simple/ui/src/test-utils.tsx | 0
.../auth/managers/simple/ui/tests-setup.ts | 0
.../auth/managers/simple/ui/vite.config.ts | 0
.../{ => api_fastapi}/auth/managers/simple/user.py | 2 +-
airflow/api_fastapi/common/db/common.py | 52 +-
airflow/api_fastapi/common/parameters.py | 11 +-
airflow/api_fastapi/core_api/base.py | 23 +
airflow/api_fastapi/core_api/datamodels/dags.py | 1 -
.../api_fastapi/core_api/datamodels/ui/config.py | 1 -
.../api_fastapi/core_api/openapi/v1-generated.yaml | 104 +-
.../api_fastapi/core_api/routes/public/assets.py | 8 +-
.../api_fastapi/core_api/routes/public/config.py | 5 +-
.../core_api/routes/public/dag_parsing.py | 4 +-
airflow/api_fastapi/core_api/routes/public/dags.py | 18 +-
.../core_api/routes/public/extra_links.py | 4 +-
airflow/api_fastapi/core_api/routes/public/job.py | 2 +
airflow/api_fastapi/core_api/routes/public/log.py | 4 +-
.../api_fastapi/core_api/routes/public/login.py | 6 +-
.../api_fastapi/core_api/routes/public/plugins.py | 9 +-
.../api_fastapi/core_api/routes/public/pools.py | 9 +-
.../core_api/routes/public/providers.py | 13 +-
.../core_api/routes/public/task_instances.py | 7 +-
airflow/api_fastapi/core_api/routes/ui/assets.py | 9 +-
airflow/api_fastapi/core_api/routes/ui/config.py | 7 +-
airflow/api_fastapi/core_api/routes/ui/grid.py | 9 +-
.../api_fastapi/core_api/routes/ui/structure.py | 2 +-
airflow/api_fastapi/core_api/security.py | 132 +-
airflow/api_fastapi/logging/decorators.py | 2 +-
airflow/assets/evaluation.py | 78 +
airflow/auth/managers/utils/__init__.py | 17 -
airflow/auth/managers/utils/fab.py | 52 -
airflow/cli/cli_config.py | 72 +-
.../commands/local_commands/standalone_command.py | 3 +-
.../cli/commands/remote_commands/dag_command.py | 82 +-
.../commands/remote_commands/provider_command.py | 5 +-
.../cli/commands/remote_commands/task_command.py | 250 +-
airflow/config_templates/config.yml | 9 +-
airflow/configuration.py | 26 +-
airflow/dag_processing/bundles/git.py | 2 +-
airflow/dag_processing/collection.py | 1 -
airflow/dag_processing/manager.py | 4 +-
airflow/decorators/base.py | 8 +-
...e_bash_operator.py => example_custom_weight.py} | 53 +-
airflow/example_dags/example_params_ui_tutorial.py | 160 +-
airflow/executors/workloads.py | 2 +-
airflow/jobs/local_task_job_runner.py | 369 -
airflow/jobs/scheduler_job_runner.py | 10 +
airflow/metrics/validators.py | 9 +-
...061_3_0_0_use_ti_id_as_primary_key_to_TINote.py | 151 +
...mn.py => 0062_3_0_0_remove_dag_default_view.py} | 19 +-
airflow/models/__init__.py | 4 +-
airflow/models/asset.py | 6 +-
airflow/models/baseoperator.py | 61 +-
airflow/models/connection.py | 6 +-
airflow/models/dag.py | 37 +-
airflow/models/dagrun.py | 6 +-
airflow/models/taskinstance.py | 45 +-
airflow/security/permissions.py | 1 +
airflow/security/utils.py | 5 +-
airflow/serialization/serde.py | 6 +-
airflow/serialization/serialized_objects.py | 5 +-
airflow/settings.py | 11 +-
airflow/task/standard_task_runner.py | 321 -
airflow/ui/dev/index.html | 2 +-
airflow/ui/index.html | 3 +-
airflow/ui/openapi-gen/queries/common.ts | 4 +-
airflow/ui/openapi-gen/queries/prefetch.ts | 9 +-
airflow/ui/openapi-gen/queries/queries.ts | 16 +-
airflow/ui/openapi-gen/queries/suspense.ts | 9 +-
airflow/ui/openapi-gen/requests/schemas.gen.ts | 41 -
airflow/ui/openapi-gen/requests/services.gen.ts | 10 +-
airflow/ui/openapi-gen/requests/types.gen.ts | 14 +-
airflow/ui/package.json | 2 +-
airflow/ui/pnpm-lock.yaml | 144 +-
airflow/ui/src/constants/searchParams.ts | 1 +
airflow/ui/src/layouts/BaseLayout.tsx | 22 +-
airflow/ui/src/layouts/Details/DetailsLayout.tsx | 5 +-
airflow/ui/src/main.tsx | 14 +-
airflow/ui/src/mocks/handlers/config.ts | 1 -
airflow/ui/src/mocks/handlers/dag.ts | 1 -
airflow/ui/src/mocks/handlers/dags.ts | 4 -
airflow/ui/src/pages/AssetsList/AssetsList.tsx | 7 +
airflow/ui/src/pages/DagsList/DagCard.test.tsx | 1 -
airflow/ui/src/pages/DagsList/DagsFilters.tsx | 2 +-
airflow/ui/src/pages/Plugins.tsx | 1 +
airflow/ui/src/pages/Providers.tsx | 1 +
airflow/ui/src/pages/TaskInstance/Logs/Logs.tsx | 3 +
.../src/pages/TaskInstance/Logs/TaskLogHeader.tsx | 64 +-
airflow/ui/src/queries/useLogs.tsx | 56 +-
airflow/ui/src/queryClient.ts | 5 +-
.../tokenHandler.test.ts} | 28 +-
.../ui/src/utils/tokenHandler.ts | 55 +-
airflow/utils/cli.py | 5 +-
airflow/utils/db.py | 2 +-
airflow/utils/db_cleanup.py | 4 +-
airflow/utils/email.py | 5 +-
airflow/utils/file.py | 14 +-
airflow/utils/helpers.py | 3 +-
airflow/utils/log/colored_log.py | 4 +-
airflow/utils/log/logging_mixin.py | 5 +-
.../pgbouncer-exporter/build_and_push.sh | 6 +-
chart/dockerfiles/pgbouncer/Dockerfile | 3 +-
chart/dockerfiles/pgbouncer/build_and_push.sh | 12 +-
chart/newsfragments/47416.significant.rst | 3 +
.../api-server/api-server-deployment.yaml | 1 +
chart/templates/flower/flower-deployment.yaml | 1 +
.../templates/scheduler/scheduler-deployment.yaml | 1 +
.../templates/webserver/webserver-deployment.yaml | 1 +
chart/values.schema.json | 24 +-
chart/values.yaml | 8 +-
clients/python/openapi_v1.yaml | 12 -
clients/python/test_python_client.py | 4 +-
codecov.yml | 2 +-
contributing-docs/03_contributors_quick_start.rst | 34 +-
contributing-docs/08_static_code_checks.rst | 9 +-
contributing-docs/testing/unit_tests.rst | 4 +-
dev/README_RELEASE_AIRFLOW.md | 6 +-
dev/README_RELEASE_PYTHON_CLIENT.md | 2 +-
dev/airflow-github | 2 +-
dev/breeze/doc/03_developer_tasks.rst | 12 +-
dev/breeze/doc/09_release_management_tasks.rst | 2 +-
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/images/output_static-checks.svg | 18 +-
dev/breeze/doc/images/output_static-checks.txt | 2 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../commands/release_management_commands.py | 4 +-
dev/breeze/src/airflow_breeze/global_constants.py | 4 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 2 -
.../templates/CHANGELOG_TEMPLATE.rst.jinja2 | 2 +-
.../airflow_breeze/utils/add_back_references.py | 20 +-
.../src/airflow_breeze/utils/selective_checks.py | 36 +-
dev/breeze/src/airflow_breeze/utils/visuals.py | 12 +-
.../tests/test_pytest_args_for_test_types.py | 1 -
dev/breeze/tests/test_selective_checks.py | 4 -
dev/breeze/uv.lock | 17 +-
devel-common/src/tests_common/test_utils/compat.py | 2 +-
docker_tests/test_docker_compose_quick_start.py | 57 +-
.../priority-weight.rst | 23 +-
.../core-concepts/auth-manager/index.rst | 6 +-
docs/apache-airflow/core-concepts/dags.rst | 4 -
docs/apache-airflow/core-concepts/params.rst | 17 +-
docs/apache-airflow/empty_plugin/empty_plugin.py | 2 +-
docs/apache-airflow/howto/define-extra-link.rst | 6 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 3350 ++-
.../img/trigger-dag-tutorial-form-1.png | Bin 0 -> 49667 bytes
.../img/trigger-dag-tutorial-form-2.png | Bin 0 -> 99562 bytes
.../img/trigger-dag-tutorial-form-3.png | Bin 0 -> 68207 bytes
.../img/trigger-dag-tutorial-form-4.png | Bin 0 -> 73829 bytes
.../img/trigger-dag-tutorial-form.png | Bin 247468 -> 0 bytes
docs/apache-airflow/migrations-ref.rst | 6 +-
docs/apache-airflow/public-airflow-interface.rst | 14 +-
docs/apache-airflow/ui.rst | 2 +-
docs/conf.py | 1 -
docs/spelling_wordlist.txt | 2 +
generated/dep_tree.txt | 49 -
generated/dependency_depth.json | 1 -
generated/provider_dependencies.json | 13 +-
hatch_build.py | 13 +-
kubernetes_tests/test_base.py | 160 +-
kubernetes_tests/test_kubernetes_executor.py | 2 +-
kubernetes_tests/test_other_executors.py | 11 +-
newsfragments/41348.significant.rst | 8 +-
newsfragments/41774.significant.rst | 1 -
newsfragments/aip-72.significant.rst | 17 +-
newsfragments/aip-79.significant.rst | 2 +
.../performance_dag/performance_dag.py | 2 +-
.../performance_dag/performance_dag_utils.py | 3 +-
performance/tests/test_performance_dag.py | 2 +-
providers/airbyte/README.rst | 6 +-
providers/airbyte/docs/changelog.rst | 33 +
providers/airbyte/docs/commits.rst | 487 +-
providers/airbyte/docs/index.rst | 2 +-
providers/airbyte/provider.yaml | 3 +-
providers/airbyte/pyproject.toml | 6 +-
.../src/airflow/providers/airbyte/__init__.py | 2 +-
.../airflow/providers/airbyte/get_provider_info.py | 3 +-
providers/alibaba/README.rst | 6 +-
providers/alibaba/docs/changelog.rst | 21 +
providers/alibaba/docs/commits.rst | 499 +-
providers/alibaba/docs/index.rst | 2 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 6 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
.../airflow/providers/alibaba/get_provider_info.py | 3 +-
providers/amazon/README.rst | 6 +-
providers/amazon/docs/changelog.rst | 51 +
providers/amazon/docs/commits.rst | 44 +
providers/amazon/docs/index.rst | 7 +-
providers/amazon/provider.yaml | 3 +-
providers/amazon/pyproject.toml | 6 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../amazon/aws/auth_manager/avp/entities.py | 3 +-
.../amazon/aws/auth_manager/avp/facade.py | 2 +-
.../amazon/aws/auth_manager/aws_auth_manager.py | 25 +-
.../amazon/aws/auth_manager/router/login.py | 3 +-
.../providers/amazon/aws/auth_manager/user.py | 11 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 25 +
.../src/airflow/providers/amazon/aws/hooks/ec2.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/glue.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/logs.py | 4 +-
.../providers/amazon/aws/hooks/redshift_cluster.py | 2 +-
.../providers/amazon/aws/hooks/redshift_data.py | 4 +-
.../providers/amazon/aws/hooks/sagemaker.py | 2 +-
.../airflow/providers/amazon/aws/links/base_aws.py | 8 +-
.../providers/amazon/aws/triggers/README.md | 8 +-
.../airflow/providers/amazon/aws/triggers/base.py | 2 +-
.../airflow/providers/amazon/aws/triggers/ecs.py | 8 +-
.../airflow/providers/amazon/aws/triggers/eks.py | 4 +-
.../airflow/providers/amazon/aws/triggers/glue.py | 2 +-
.../airflow/providers/amazon/aws/triggers/s3.py | 4 +-
.../providers/amazon/aws/triggers/sagemaker.py | 4 +-
.../airflow/providers/amazon/aws/triggers/sqs.py | 2 +-
.../airflow/providers/amazon/get_provider_info.py | 3 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 2 +-
.../aws/auth_manager/test_aws_auth_manager.py | 39 +-
.../unit/amazon/aws/hooks/test_redshift_data.py | 16 +-
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 109 +-
.../tests/unit/amazon/aws/triggers/test_base.py | 4 +-
.../tests/unit/amazon/aws/triggers/test_bedrock.py | 8 +-
.../unit/amazon/aws/triggers/test_comprehend.py | 4 +-
.../tests/unit/amazon/aws/triggers/test_dms.py | 12 +-
.../tests/unit/amazon/aws/triggers/test_ec2.py | 8 +-
.../tests/unit/amazon/aws/triggers/test_ecs.py | 18 +-
.../tests/unit/amazon/aws/triggers/test_eks.py | 4 +-
.../tests/unit/amazon/aws/triggers/test_glue.py | 4 +-
.../unit/amazon/aws/triggers/test_glue_crawler.py | 2 +-
.../amazon/aws/triggers/test_kinesis_analytics.py | 4 +-
.../tests/unit/amazon/aws/triggers/test_neptune.py | 16 +-
.../aws/triggers/test_opensearch_serverless.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_s3.py | 14 +-
.../unit/amazon/aws/triggers/test_sagemaker.py | 4 +-
.../unit/amazon/aws/triggers/test_serialization.py | 3 -
providers/apache/beam/README.rst | 6 +-
providers/apache/beam/docs/changelog.rst | 20 +
providers/apache/beam/docs/commits.rst | 17 +
providers/apache/beam/docs/index.rst | 6 +-
providers/apache/beam/provider.yaml | 3 +-
providers/apache/beam/pyproject.toml | 6 +-
.../src/airflow/providers/apache/beam/__init__.py | 2 +-
.../providers/apache/beam/get_provider_info.py | 3 +-
providers/apache/cassandra/README.rst | 6 +-
providers/apache/cassandra/docs/changelog.rst | 20 +
providers/apache/cassandra/docs/commits.rst | 550 +-
providers/apache/cassandra/docs/index.rst | 2 +-
providers/apache/cassandra/provider.yaml | 3 +-
providers/apache/cassandra/pyproject.toml | 6 +-
.../airflow/providers/apache/cassandra/__init__.py | 2 +-
.../apache/cassandra/get_provider_info.py | 3 +-
providers/apache/drill/README.rst | 6 +-
providers/apache/drill/docs/changelog.rst | 23 +
providers/apache/drill/docs/commits.rst | 495 +-
providers/apache/drill/docs/index.rst | 6 +-
providers/apache/drill/provider.yaml | 3 +-
providers/apache/drill/pyproject.toml | 6 +-
.../src/airflow/providers/apache/drill/__init__.py | 2 +-
.../providers/apache/drill/get_provider_info.py | 3 +-
providers/apache/druid/README.rst | 6 +-
providers/apache/druid/docs/changelog.rst | 25 +
providers/apache/druid/docs/commits.rst | 717 +-
providers/apache/druid/docs/index.rst | 6 +-
providers/apache/druid/provider.yaml | 3 +-
providers/apache/druid/pyproject.toml | 6 +-
.../src/airflow/providers/apache/druid/__init__.py | 2 +-
.../providers/apache/druid/get_provider_info.py | 3 +-
providers/apache/flink/README.rst | 6 +-
providers/apache/flink/docs/changelog.rst | 19 +
providers/apache/flink/docs/commits.rst | 281 +-
providers/apache/flink/docs/index.rst | 6 +-
providers/apache/flink/provider.yaml | 3 +-
providers/apache/flink/pyproject.toml | 6 +-
.../src/airflow/providers/apache/flink/__init__.py | 2 +-
.../providers/apache/flink/get_provider_info.py | 3 +-
providers/apache/hdfs/README.rst | 6 +-
providers/apache/hdfs/docs/changelog.rst | 21 +
providers/apache/hdfs/docs/commits.rst | 665 +-
providers/apache/hdfs/docs/index.rst | 2 +-
providers/apache/hdfs/provider.yaml | 3 +-
providers/apache/hdfs/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hdfs/__init__.py | 2 +-
.../providers/apache/hdfs/get_provider_info.py | 3 +-
providers/apache/hive/README.rst | 6 +-
providers/apache/hive/docs/changelog.rst | 15 +
providers/apache/hive/docs/commits.rst | 16 +
providers/apache/hive/docs/index.rst | 6 +-
providers/apache/hive/provider.yaml | 3 +-
providers/apache/hive/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hive/__init__.py | 2 +-
.../providers/apache/hive/get_provider_info.py | 3 +-
providers/apache/iceberg/README.rst | 6 +-
providers/apache/iceberg/docs/changelog.rst | 23 +
providers/apache/iceberg/docs/commits.rst | 85 +-
providers/apache/iceberg/docs/index.rst | 2 +-
providers/apache/iceberg/provider.yaml | 3 +-
providers/apache/iceberg/pyproject.toml | 6 +-
.../airflow/providers/apache/iceberg/__init__.py | 2 +-
.../providers/apache/iceberg/get_provider_info.py | 4 +-
providers/apache/impala/README.rst | 6 +-
providers/apache/impala/docs/changelog.rst | 19 +
providers/apache/impala/docs/commits.rst | 267 +-
providers/apache/impala/docs/index.rst | 6 +-
providers/apache/impala/provider.yaml | 3 +-
providers/apache/impala/pyproject.toml | 6 +-
.../airflow/providers/apache/impala/__init__.py | 2 +-
.../providers/apache/impala/get_provider_info.py | 3 +-
providers/apache/kylin/README.rst | 6 +-
providers/apache/kylin/docs/changelog.rst | 21 +
providers/apache/kylin/docs/commits.rst | 497 +-
providers/apache/kylin/docs/index.rst | 2 +-
providers/apache/kylin/provider.yaml | 3 +-
providers/apache/kylin/pyproject.toml | 6 +-
.../src/airflow/providers/apache/kylin/__init__.py | 2 +-
.../providers/apache/kylin/get_provider_info.py | 3 +-
providers/apache/livy/README.rst | 6 +-
providers/apache/livy/docs/changelog.rst | 15 +
providers/apache/livy/docs/commits.rst | 16 +
providers/apache/livy/docs/index.rst | 6 +-
providers/apache/livy/provider.yaml | 3 +-
providers/apache/livy/pyproject.toml | 6 +-
.../src/airflow/providers/apache/livy/__init__.py | 2 +-
.../providers/apache/livy/get_provider_info.py | 3 +-
providers/apache/pig/README.rst | 6 +-
providers/apache/pig/docs/changelog.rst | 20 +
providers/apache/pig/docs/commits.rst | 512 +-
providers/apache/pig/docs/index.rst | 2 +-
providers/apache/pig/provider.yaml | 3 +-
providers/apache/pig/pyproject.toml | 6 +-
.../src/airflow/providers/apache/pig/__init__.py | 2 +-
.../providers/apache/pig/get_provider_info.py | 3 +-
providers/apache/pinot/README.rst | 6 +-
providers/apache/pinot/docs/changelog.rst | 25 +
providers/apache/pinot/docs/commits.rst | 567 +-
providers/apache/pinot/docs/index.rst | 6 +-
providers/apache/pinot/provider.yaml | 3 +-
providers/apache/pinot/pyproject.toml | 6 +-
.../src/airflow/providers/apache/pinot/__init__.py | 2 +-
.../providers/apache/pinot/get_provider_info.py | 3 +-
.../airflow/providers/apache/pinot/hooks/pinot.py | 26 +-
.../tests/unit/apache/pinot/hooks/test_pinot.py | 192 +
providers/apache/spark/README.rst | 6 +-
providers/apache/spark/docs/changelog.rst | 31 +
providers/apache/spark/docs/commits.rst | 653 +-
providers/apache/spark/docs/index.rst | 6 +-
providers/apache/spark/provider.yaml | 3 +-
providers/apache/spark/pyproject.toml | 6 +-
.../src/airflow/providers/apache/spark/__init__.py | 2 +-
.../providers/apache/spark/get_provider_info.py | 3 +-
providers/apprise/README.rst | 6 +-
providers/apprise/docs/changelog.rst | 20 +
providers/apprise/docs/commits.rst | 254 +-
providers/apprise/docs/index.rst | 2 +-
providers/apprise/provider.yaml | 3 +-
providers/apprise/pyproject.toml | 6 +-
.../src/airflow/providers/apprise/__init__.py | 2 +-
.../airflow/providers/apprise/get_provider_info.py | 3 +-
providers/arangodb/README.rst | 6 +-
providers/arangodb/docs/changelog.rst | 15 +
providers/arangodb/docs/commits.rst | 16 +
providers/arangodb/docs/index.rst | 2 +-
providers/arangodb/provider.yaml | 3 +-
providers/arangodb/pyproject.toml | 6 +-
.../src/airflow/providers/arangodb/__init__.py | 2 +-
.../providers/arangodb/get_provider_info.py | 3 +-
providers/asana/README.rst | 6 +-
providers/asana/docs/changelog.rst | 15 +
providers/asana/docs/commits.rst | 16 +
providers/asana/docs/index.rst | 2 +-
providers/asana/provider.yaml | 3 +-
providers/asana/pyproject.toml | 6 +-
.../asana/src/airflow/providers/asana/__init__.py | 2 +-
.../airflow/providers/asana/get_provider_info.py | 3 +-
providers/atlassian/jira/README.rst | 6 +-
providers/atlassian/jira/docs/changelog.rst | 20 +
providers/atlassian/jira/docs/commits.rst | 320 +-
providers/atlassian/jira/docs/index.rst | 2 +-
providers/atlassian/jira/provider.yaml | 3 +-
providers/atlassian/jira/pyproject.toml | 6 +-
.../airflow/providers/atlassian/jira/__init__.py | 2 +-
.../providers/atlassian/jira/get_provider_info.py | 3 +-
providers/celery/README.rst | 7 +-
providers/celery/docs/changelog.rst | 27 +
providers/celery/docs/commits.rst | 24 +
providers/celery/docs/index.rst | 7 +-
providers/celery/provider.yaml | 3 +-
providers/celery/pyproject.toml | 7 +-
.../src/airflow/providers/celery/__init__.py | 2 +-
.../celery/executors/celery_executor_utils.py | 7 +-
.../providers/celery/executors/default_celery.py | 7 +-
.../airflow/providers/celery/get_provider_info.py | 10 +-
providers/cloudant/README.rst | 6 +-
providers/cloudant/docs/changelog.rst | 19 +
providers/cloudant/docs/commits.rst | 509 +-
providers/cloudant/docs/index.rst | 2 +-
providers/cloudant/provider.yaml | 3 +-
providers/cloudant/pyproject.toml | 6 +-
.../src/airflow/providers/cloudant/__init__.py | 2 +-
.../providers/cloudant/get_provider_info.py | 3 +-
providers/cncf/kubernetes/README.rst | 7 +-
providers/cncf/kubernetes/docs/changelog.rst | 19 +
providers/cncf/kubernetes/docs/commits.rst | 20 +
providers/cncf/kubernetes/docs/index.rst | 3 +-
providers/cncf/kubernetes/provider.yaml | 3 +-
providers/cncf/kubernetes/pyproject.toml | 7 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../providers/cncf/kubernetes/get_provider_info.py | 4 +-
.../providers/cncf/kubernetes/pod_generator.py | 4 +-
providers/cohere/README.rst | 6 +-
providers/cohere/docs/changelog.rst | 15 +
providers/cohere/docs/commits.rst | 16 +
providers/cohere/docs/index.rst | 2 +-
providers/cohere/provider.yaml | 3 +-
providers/cohere/pyproject.toml | 6 +-
.../src/airflow/providers/cohere/__init__.py | 2 +-
.../airflow/providers/cohere/get_provider_info.py | 3 +-
providers/common/compat/README.rst | 6 +-
providers/common/compat/docs/changelog.rst | 16 +
providers/common/compat/docs/commits.rst | 17 +
providers/common/compat/docs/index.rst | 6 +-
providers/common/compat/provider.yaml | 3 +-
providers/common/compat/pyproject.toml | 6 +-
.../airflow/providers/common/compat/__init__.py | 2 +-
.../providers/common/compat/assets/__init__.py | 5 +-
.../providers/common/compat/get_provider_info.py | 4 +-
.../common/compat/security/permissions.py | 6 +-
providers/common/io/README.rst | 6 +-
providers/common/io/docs/changelog.rst | 26 +
providers/common/io/docs/commits.rst | 246 +-
providers/common/io/docs/index.rst | 6 +-
providers/common/io/provider.yaml | 3 +-
providers/common/io/pyproject.toml | 6 +-
.../io/src/airflow/providers/common/io/__init__.py | 2 +-
.../providers/common/io/get_provider_info.py | 3 +-
providers/common/sql/README.rst | 6 +-
providers/common/sql/docs/changelog.rst | 26 +
providers/common/sql/docs/commits.rst | 19 +
providers/common/sql/docs/index.rst | 6 +-
providers/common/sql/provider.yaml | 3 +-
providers/common/sql/pyproject.toml | 6 +-
.../src/airflow/providers/common/sql/__init__.py | 2 +-
.../providers/common/sql/get_provider_info.py | 3 +-
providers/databricks/README.rst | 6 +-
providers/databricks/docs/changelog.rst | 25 +
providers/databricks/docs/commits.rst | 22 +
providers/databricks/docs/index.rst | 6 +-
providers/databricks/provider.yaml | 3 +-
providers/databricks/pyproject.toml | 6 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../providers/databricks/get_provider_info.py | 3 +-
.../providers/databricks/operators/databricks.py | 8 +-
.../databricks/plugins/databricks_workflow.py | 13 +-
providers/datadog/README.rst | 6 +-
providers/datadog/docs/changelog.rst | 15 +
providers/datadog/docs/commits.rst | 16 +
providers/datadog/docs/index.rst | 2 +-
providers/datadog/provider.yaml | 3 +-
providers/datadog/pyproject.toml | 6 +-
.../src/airflow/providers/datadog/__init__.py | 2 +-
.../airflow/providers/datadog/get_provider_info.py | 3 +-
providers/dbt/cloud/README.rst | 21 +-
providers/dbt/cloud/docs/changelog.rst | 16 +
providers/dbt/cloud/docs/commits.rst | 17 +
providers/dbt/cloud/docs/index.rst | 21 +-
providers/dbt/cloud/provider.yaml | 3 +-
providers/dbt/cloud/pyproject.toml | 10 +-
.../src/airflow/providers/dbt/cloud/__init__.py | 2 +-
.../providers/dbt/cloud/get_provider_info.py | 8 +-
.../airflow/providers/dbt/cloud/operators/dbt.py | 18 +-
.../providers/dbt/cloud/utils/openlineage.py | 82 +-
.../airflow/providers/dbt/cloud}/version_compat.py | 0
providers/dingding/README.rst | 6 +-
providers/dingding/docs/changelog.rst | 15 +
providers/dingding/docs/commits.rst | 16 +
providers/dingding/docs/index.rst | 6 +-
providers/dingding/provider.yaml | 3 +-
providers/dingding/pyproject.toml | 6 +-
.../src/airflow/providers/dingding/__init__.py | 2 +-
.../providers/dingding/get_provider_info.py | 3 +-
providers/discord/README.rst | 6 +-
providers/discord/docs/changelog.rst | 15 +
providers/discord/docs/commits.rst | 16 +
providers/discord/docs/index.rst | 6 +-
providers/discord/provider.yaml | 3 +-
providers/discord/pyproject.toml | 6 +-
.../src/airflow/providers/discord/__init__.py | 2 +-
.../airflow/providers/discord/get_provider_info.py | 3 +-
providers/docker/README.rst | 6 +-
providers/docker/docs/changelog.rst | 15 +
providers/docker/docs/commits.rst | 16 +
providers/docker/docs/index.rst | 6 +-
providers/docker/provider.yaml | 3 +-
providers/docker/pyproject.toml | 6 +-
.../src/airflow/providers/docker/__init__.py | 2 +-
.../airflow/providers/docker/get_provider_info.py | 3 +-
.../providers/edge/plugins/edge_executor_plugin.py | 6 +-
providers/elasticsearch/README.rst | 6 +-
providers/elasticsearch/docs/changelog.rst | 16 +
providers/elasticsearch/docs/commits.rst | 17 +
providers/elasticsearch/docs/index.rst | 6 +-
providers/elasticsearch/provider.yaml | 3 +-
providers/elasticsearch/pyproject.toml | 6 +-
.../airflow/providers/elasticsearch/__init__.py | 2 +-
.../providers/elasticsearch/get_provider_info.py | 3 +-
providers/exasol/README.rst | 6 +-
providers/exasol/docs/changelog.rst | 20 +
providers/exasol/docs/commits.rst | 17 +
providers/exasol/docs/index.rst | 6 +-
providers/exasol/provider.yaml | 3 +-
providers/exasol/pyproject.toml | 6 +-
.../src/airflow/providers/exasol/__init__.py | 2 +-
.../airflow/providers/exasol/get_provider_info.py | 3 +-
providers/fab/README.rst | 2 +-
providers/fab/docs/index.rst | 1 -
providers/fab/pyproject.toml | 2 +-
.../auth_manager/api/auth/backend/kerberos_auth.py | 2 +-
.../fab/auth_manager/api_fastapi/services/login.py | 2 +-
.../fab/auth_manager/cli_commands/user_command.py | 4 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 48 +-
.../providers/fab/auth_manager/models/__init__.py | 2 +-
.../fab/auth_manager/models/anonymous_user.py | 2 +-
.../fab/auth_manager/security_manager/override.py | 493 +-
.../src/airflow/providers/fab/get_provider_info.py | 2 +-
.../providers/fab/www/api_connexion/security.py | 2 +-
providers/fab/src/airflow/providers/fab/www/app.py | 12 +-
.../fab/src/airflow/providers/fab/www/auth.py | 6 +-
.../fab/www/extensions/init_appbuilder.py | 6 +-
.../airflow/providers/fab/www/package-lock.json | 20357 +++++--------------
.../fab/src/airflow/providers/fab/www/package.json | 87 +-
.../providers/fab/www/security/permissions.py | 1 +
.../airflow/providers/fab/www/security_manager.py | 217 +-
.../www/static/css/{loading-dots.css => flash.css} | 55 +-
.../providers/fab/www/static/dist/d3-tip.js | 1 -
.../www/static/dist/flash.137b30cff85b5588e661.css | 11 +-
.../www/static/dist/flash.137b30cff85b5588e661.js | 1 +
.../fab/www/static/dist/jquery-ui.min.css | 5 +
.../providers/fab/www/static/dist/jquery-ui.min.js | 2 +
.../www/static/dist/jquery-ui.min.js.LICENSE.txt | 4 +
...6bd076c4f.css => main.ec1d38d994d72bb083cd.css} | 0
...c96bd076c4f.js => main.ec1d38d994d72bb083cd.js} | 2 +-
...xt => main.ec1d38d994d72bb083cd.js.LICENSE.txt} | 0
.../providers/fab/www/static/dist/manifest.json | 31 +-
.../providers/fab/www/templates/airflow/main.html | 1 +
.../fab/www/templates/appbuilder/flash.html | 31 +-
.../fab/src/airflow/providers/fab/www/utils.py | 29 +
.../fab/src/airflow/providers/fab/www/views.py | 4 +-
.../airflow/providers/fab/www/webpack.config.js | 44 +-
.../api_fastapi/services/test_login.py | 2 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 19 +-
.../tests/unit/fab/auth_manager/test_security.py | 35 +-
providers/fab/tests/unit/fab/www/test_auth.py | 2 +-
.../fab/www/views/test_views_custom_user_views.py | 2 +-
providers/facebook/README.rst | 6 +-
providers/facebook/docs/changelog.rst | 19 +
providers/facebook/docs/commits.rst | 519 +-
providers/facebook/docs/index.rst | 2 +-
providers/facebook/provider.yaml | 3 +-
providers/facebook/pyproject.toml | 6 +-
.../src/airflow/providers/facebook/__init__.py | 2 +-
.../providers/facebook/get_provider_info.py | 3 +-
providers/ftp/README.rst | 6 +-
providers/ftp/docs/changelog.rst | 15 +
providers/ftp/docs/commits.rst | 16 +
providers/ftp/docs/index.rst | 6 +-
providers/ftp/provider.yaml | 3 +-
providers/ftp/pyproject.toml | 6 +-
.../ftp/src/airflow/providers/ftp/__init__.py | 2 +-
.../src/airflow/providers/ftp/get_provider_info.py | 3 +-
providers/github/README.rst | 6 +-
providers/github/docs/changelog.rst | 15 +
providers/github/docs/commits.rst | 16 +
providers/github/docs/index.rst | 2 +-
providers/github/provider.yaml | 3 +-
providers/github/pyproject.toml | 6 +-
.../src/airflow/providers/github/__init__.py | 2 +-
.../airflow/providers/github/get_provider_info.py | 3 +-
providers/google/README.rst | 2 +-
providers/google/docs/.latest-doc-only-change.txt | 2 +-
providers/google/docs/operators/cloud/dataflow.rst | 8 +
providers/google/pyproject.toml | 2 +-
.../src/airflow/providers/google/ads/hooks/ads.py | 10 +-
.../airflow/providers/google/cloud/links/base.py | 7 +-
.../providers/google/cloud/links/datafusion.py | 9 +-
.../providers/google/cloud/links/dataproc.py | 8 +-
.../providers/google/cloud/operators/dataproc.py | 27 +
.../google/cloud/operators/dataproc_metastore.py | 8 +
.../airflow/providers/google/get_provider_info.py | 2 +-
.../marketing_platform/links/analytics_admin.py | 9 +-
..._java.py => example_dataflow_java_streaming.py} | 136 +-
.../non_python_src/java_streaming_src/README.MD | 58 +
.../non_python_src/java_streaming_src/pom.xml | 131 +
.../java/org/example/pubsub/StreamingExample.java | 42 +
.../unit/google/cloud/operators/test_dataproc.py | 108 +-
providers/grpc/README.rst | 6 +-
providers/grpc/docs/changelog.rst | 15 +
providers/grpc/docs/commits.rst | 16 +
providers/grpc/docs/index.rst | 2 +-
providers/grpc/provider.yaml | 3 +-
providers/grpc/pyproject.toml | 6 +-
.../grpc/src/airflow/providers/grpc/__init__.py | 2 +-
.../airflow/providers/grpc/get_provider_info.py | 3 +-
providers/hashicorp/README.rst | 6 +-
providers/hashicorp/docs/changelog.rst | 24 +
providers/hashicorp/docs/commits.rst | 682 +-
providers/hashicorp/docs/index.rst | 6 +-
providers/hashicorp/provider.yaml | 3 +-
providers/hashicorp/pyproject.toml | 6 +-
.../src/airflow/providers/hashicorp/__init__.py | 2 +-
.../hashicorp/_internal_client/vault_client.py | 11 +-
.../providers/hashicorp/get_provider_info.py | 3 +-
.../src/airflow/providers/hashicorp/hooks/vault.py | 5 +
.../airflow/providers/hashicorp/secrets/vault.py | 3 +
.../_internal_client/test_vault_client.py | 24 +
.../tests/unit/hashicorp/hooks/test_vault.py | 15 +-
providers/http/README.rst | 6 +-
providers/http/docs/changelog.rst | 20 +
providers/http/docs/commits.rst | 17 +
providers/http/docs/index.rst | 4 +-
providers/http/provider.yaml | 3 +-
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../airflow/providers/http/get_provider_info.py | 3 +-
providers/imap/README.rst | 6 +-
providers/imap/docs/changelog.rst | 15 +
providers/imap/docs/commits.rst | 16 +
providers/imap/docs/index.rst | 2 +-
providers/imap/provider.yaml | 3 +-
providers/imap/pyproject.toml | 6 +-
.../imap/src/airflow/providers/imap/__init__.py | 2 +-
.../airflow/providers/imap/get_provider_info.py | 3 +-
providers/influxdb/README.rst | 6 +-
providers/influxdb/docs/changelog.rst | 15 +
providers/influxdb/docs/commits.rst | 16 +
providers/influxdb/docs/index.rst | 2 +-
providers/influxdb/provider.yaml | 3 +-
providers/influxdb/pyproject.toml | 6 +-
.../src/airflow/providers/influxdb/__init__.py | 2 +-
.../providers/influxdb/get_provider_info.py | 3 +-
providers/jdbc/README.rst | 6 +-
providers/jdbc/docs/changelog.rst | 21 +
providers/jdbc/docs/commits.rst | 681 +-
providers/jdbc/docs/index.rst | 6 +-
providers/jdbc/provider.yaml | 3 +-
providers/jdbc/pyproject.toml | 6 +-
.../jdbc/src/airflow/providers/jdbc/__init__.py | 2 +-
.../airflow/providers/jdbc/get_provider_info.py | 3 +-
providers/jenkins/README.rst | 6 +-
providers/jenkins/docs/changelog.rst | 15 +
providers/jenkins/docs/commits.rst | 16 +
providers/jenkins/docs/index.rst | 2 +-
providers/jenkins/provider.yaml | 3 +-
providers/jenkins/pyproject.toml | 6 +-
.../src/airflow/providers/jenkins/__init__.py | 2 +-
.../airflow/providers/jenkins/get_provider_info.py | 3 +-
providers/microsoft/azure/README.rst | 6 +-
providers/microsoft/azure/docs/changelog.rst | 23 +
providers/microsoft/azure/docs/commits.rst | 20 +
providers/microsoft/azure/docs/index.rst | 6 +-
providers/microsoft/azure/provider.yaml | 3 +-
providers/microsoft/azure/pyproject.toml | 6 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../providers/microsoft/azure/get_provider_info.py | 3 +-
.../microsoft/azure/operators/data_factory.py | 9 +-
.../providers/microsoft/azure/operators/powerbi.py | 9 +-
.../providers/microsoft/azure/operators/synapse.py | 9 +-
.../microsoft/azure/example_adf_run_pipeline.py | 1 -
providers/microsoft/mssql/README.rst | 6 +-
providers/microsoft/mssql/docs/changelog.rst | 20 +
providers/microsoft/mssql/docs/commits.rst | 17 +
providers/microsoft/mssql/docs/index.rst | 6 +-
providers/microsoft/mssql/provider.yaml | 3 +-
providers/microsoft/mssql/pyproject.toml | 6 +-
.../airflow/providers/microsoft/mssql/__init__.py | 2 +-
.../providers/microsoft/mssql/get_provider_info.py | 3 +-
providers/microsoft/psrp/README.rst | 6 +-
providers/microsoft/psrp/docs/changelog.rst | 19 +
providers/microsoft/psrp/docs/commits.rst | 409 +-
providers/microsoft/psrp/docs/index.rst | 2 +-
providers/microsoft/psrp/provider.yaml | 3 +-
providers/microsoft/psrp/pyproject.toml | 6 +-
.../airflow/providers/microsoft/psrp/__init__.py | 2 +-
.../providers/microsoft/psrp/get_provider_info.py | 3 +-
providers/microsoft/winrm/README.rst | 6 +-
providers/microsoft/winrm/docs/changelog.rst | 15 +
providers/microsoft/winrm/docs/commits.rst | 16 +
providers/microsoft/winrm/docs/index.rst | 2 +-
providers/microsoft/winrm/provider.yaml | 3 +-
providers/microsoft/winrm/pyproject.toml | 6 +-
.../airflow/providers/microsoft/winrm/__init__.py | 2 +-
.../providers/microsoft/winrm/get_provider_info.py | 3 +-
providers/mongo/README.rst | 6 +-
providers/mongo/docs/changelog.rst | 17 +
providers/mongo/docs/commits.rst | 20 +-
providers/mongo/docs/index.rst | 2 +-
providers/mongo/provider.yaml | 3 +-
providers/mongo/pyproject.toml | 6 +-
.../mongo/src/airflow/providers/mongo/__init__.py | 2 +-
.../airflow/providers/mongo/get_provider_info.py | 3 +-
providers/mysql/README.rst | 6 +-
providers/mysql/docs/changelog.rst | 26 +
providers/mysql/docs/commits.rst | 21 +-
providers/mysql/docs/index.rst | 6 +-
providers/mysql/provider.yaml | 3 +-
providers/mysql/pyproject.toml | 6 +-
.../mysql/src/airflow/providers/mysql/__init__.py | 2 +-
.../airflow/providers/mysql/get_provider_info.py | 3 +-
providers/neo4j/README.rst | 6 +-
providers/neo4j/docs/changelog.rst | 15 +
providers/neo4j/docs/commits.rst | 18 +-
providers/neo4j/docs/index.rst | 2 +-
providers/neo4j/provider.yaml | 3 +-
providers/neo4j/pyproject.toml | 6 +-
.../neo4j/src/airflow/providers/neo4j/__init__.py | 2 +-
.../airflow/providers/neo4j/get_provider_info.py | 3 +-
providers/odbc/README.rst | 6 +-
providers/odbc/docs/changelog.rst | 22 +
providers/odbc/docs/commits.rst | 610 +-
providers/odbc/docs/index.rst | 6 +-
providers/odbc/provider.yaml | 3 +-
providers/odbc/pyproject.toml | 6 +-
.../odbc/src/airflow/providers/odbc/__init__.py | 2 +-
.../airflow/providers/odbc/get_provider_info.py | 3 +-
providers/openai/README.rst | 6 +-
providers/openai/docs/changelog.rst | 15 +
providers/openai/docs/commits.rst | 18 +-
providers/openai/docs/index.rst | 2 +-
providers/openai/provider.yaml | 3 +-
providers/openai/pyproject.toml | 6 +-
.../src/airflow/providers/openai/__init__.py | 2 +-
.../airflow/providers/openai/get_provider_info.py | 3 +-
providers/openfaas/README.rst | 6 +-
providers/openfaas/docs/changelog.rst | 19 +
providers/openfaas/docs/commits.rst | 425 +-
providers/openfaas/docs/index.rst | 2 +-
providers/openfaas/provider.yaml | 3 +-
providers/openfaas/pyproject.toml | 6 +-
.../src/airflow/providers/openfaas/__init__.py | 2 +-
.../providers/openfaas/get_provider_info.py | 3 +-
providers/openlineage/README.rst | 6 +-
providers/openlineage/docs/changelog.rst | 28 +
providers/openlineage/docs/commits.rst | 25 +
providers/openlineage/docs/index.rst | 7 +-
providers/openlineage/provider.yaml | 20 +-
providers/openlineage/pyproject.toml | 6 +-
.../src/airflow/providers/openlineage/__init__.py | 2 +-
.../providers/openlineage/get_provider_info.py | 9 +-
.../providers/openlineage/plugins/listener.py | 6 +-
.../unit/openlineage/plugins/test_execution.py | 5 +-
providers/opensearch/README.rst | 6 +-
providers/opensearch/docs/changelog.rst | 17 +
providers/opensearch/docs/commits.rst | 20 +-
providers/opensearch/docs/index.rst | 2 +-
providers/opensearch/provider.yaml | 3 +-
providers/opensearch/pyproject.toml | 6 +-
.../src/airflow/providers/opensearch/__init__.py | 2 +-
.../providers/opensearch/get_provider_info.py | 3 +-
providers/opsgenie/README.rst | 6 +-
providers/opsgenie/docs/changelog.rst | 15 +
providers/opsgenie/docs/commits.rst | 18 +-
providers/opsgenie/docs/index.rst | 2 +-
providers/opsgenie/provider.yaml | 3 +-
providers/opsgenie/pyproject.toml | 6 +-
.../src/airflow/providers/opsgenie/__init__.py | 2 +-
.../providers/opsgenie/get_provider_info.py | 3 +-
providers/oracle/README.rst | 6 +-
providers/oracle/docs/changelog.rst | 15 +
providers/oracle/docs/commits.rst | 18 +-
providers/oracle/docs/index.rst | 6 +-
providers/oracle/provider.yaml | 3 +-
providers/oracle/pyproject.toml | 6 +-
.../src/airflow/providers/oracle/__init__.py | 2 +-
.../airflow/providers/oracle/get_provider_info.py | 3 +-
providers/pagerduty/README.rst | 6 +-
providers/pagerduty/docs/changelog.rst | 15 +
providers/pagerduty/docs/commits.rst | 18 +-
providers/pagerduty/docs/index.rst | 2 +-
providers/pagerduty/provider.yaml | 3 +-
providers/pagerduty/pyproject.toml | 6 +-
.../src/airflow/providers/pagerduty/__init__.py | 2 +-
.../providers/pagerduty/get_provider_info.py | 3 +-
providers/papermill/README.rst | 6 +-
providers/papermill/docs/changelog.rst | 15 +
providers/papermill/docs/commits.rst | 18 +-
providers/papermill/docs/index.rst | 6 +-
providers/papermill/provider.yaml | 3 +-
providers/papermill/pyproject.toml | 6 +-
.../src/airflow/providers/papermill/__init__.py | 2 +-
.../providers/papermill/get_provider_info.py | 3 +-
providers/pgvector/README.rst | 6 +-
providers/pgvector/docs/changelog.rst | 19 +
providers/pgvector/docs/commits.rst | 145 +-
providers/pgvector/docs/index.rst | 6 +-
providers/pgvector/provider.yaml | 3 +-
providers/pgvector/pyproject.toml | 6 +-
.../src/airflow/providers/pgvector/__init__.py | 2 +-
.../providers/pgvector/get_provider_info.py | 4 +-
providers/pinecone/README.rst | 6 +-
providers/pinecone/docs/changelog.rst | 20 +
providers/pinecone/docs/commits.rst | 19 +-
providers/pinecone/docs/index.rst | 2 +-
providers/pinecone/provider.yaml | 3 +-
providers/pinecone/pyproject.toml | 6 +-
.../src/airflow/providers/pinecone/__init__.py | 2 +-
.../providers/pinecone/get_provider_info.py | 3 +-
providers/postgres/README.rst | 6 +-
providers/postgres/docs/changelog.rst | 15 +
providers/postgres/docs/commits.rst | 18 +-
providers/postgres/docs/index.rst | 6 +-
providers/postgres/provider.yaml | 3 +-
providers/postgres/pyproject.toml | 6 +-
.../src/airflow/providers/postgres/__init__.py | 2 +-
.../providers/postgres/get_provider_info.py | 3 +-
providers/presto/README.rst | 6 +-
providers/presto/docs/changelog.rst | 15 +
providers/presto/docs/commits.rst | 18 +-
providers/presto/docs/index.rst | 6 +-
providers/presto/provider.yaml | 3 +-
providers/presto/pyproject.toml | 6 +-
.../src/airflow/providers/presto/__init__.py | 2 +-
.../airflow/providers/presto/get_provider_info.py | 3 +-
providers/qdrant/README.rst | 6 +-
providers/qdrant/docs/changelog.rst | 15 +
providers/qdrant/docs/commits.rst | 18 +-
providers/qdrant/docs/index.rst | 2 +-
providers/qdrant/provider.yaml | 3 +-
providers/qdrant/pyproject.toml | 6 +-
.../src/airflow/providers/qdrant/__init__.py | 2 +-
.../airflow/providers/qdrant/get_provider_info.py | 4 +-
providers/redis/README.rst | 6 +-
providers/redis/docs/changelog.rst | 16 +
providers/redis/docs/commits.rst | 19 +-
providers/redis/docs/index.rst | 2 +-
providers/redis/provider.yaml | 3 +-
providers/redis/pyproject.toml | 6 +-
.../redis/src/airflow/providers/redis/__init__.py | 2 +-
.../airflow/providers/redis/get_provider_info.py | 3 +-
providers/salesforce/README.rst | 6 +-
providers/salesforce/docs/changelog.rst | 15 +
providers/salesforce/docs/commits.rst | 18 +-
providers/salesforce/docs/index.rst | 2 +-
providers/salesforce/provider.yaml | 3 +-
providers/salesforce/pyproject.toml | 6 +-
.../src/airflow/providers/salesforce/__init__.py | 2 +-
.../providers/salesforce/get_provider_info.py | 3 +-
providers/samba/README.rst | 6 +-
providers/samba/docs/changelog.rst | 15 +
providers/samba/docs/commits.rst | 18 +-
providers/samba/docs/index.rst | 6 +-
providers/samba/provider.yaml | 3 +-
providers/samba/pyproject.toml | 6 +-
.../samba/src/airflow/providers/samba/__init__.py | 2 +-
.../airflow/providers/samba/get_provider_info.py | 3 +-
providers/segment/README.rst | 6 +-
providers/segment/docs/changelog.rst | 15 +
providers/segment/docs/commits.rst | 18 +-
providers/segment/docs/index.rst | 2 +-
providers/segment/provider.yaml | 3 +-
providers/segment/pyproject.toml | 6 +-
.../src/airflow/providers/segment/__init__.py | 2 +-
.../airflow/providers/segment/get_provider_info.py | 3 +-
providers/sendgrid/README.rst | 6 +-
providers/sendgrid/docs/changelog.rst | 19 +
providers/sendgrid/docs/commits.rst | 389 +-
providers/sendgrid/docs/index.rst | 2 +-
providers/sendgrid/provider.yaml | 3 +-
providers/sendgrid/pyproject.toml | 6 +-
.../src/airflow/providers/sendgrid/__init__.py | 2 +-
.../providers/sendgrid/get_provider_info.py | 3 +-
providers/sftp/README.rst | 6 +-
providers/sftp/docs/changelog.rst | 22 +
providers/sftp/docs/commits.rst | 21 +-
providers/sftp/docs/index.rst | 6 +-
providers/sftp/provider.yaml | 3 +-
providers/sftp/pyproject.toml | 6 +-
.../sftp/src/airflow/providers/sftp/__init__.py | 2 +-
.../airflow/providers/sftp/get_provider_info.py | 3 +-
providers/singularity/README.rst | 6 +-
providers/singularity/docs/changelog.rst | 20 +
providers/singularity/docs/commits.rst | 492 +-
providers/singularity/docs/index.rst | 2 +-
providers/singularity/provider.yaml | 3 +-
providers/singularity/pyproject.toml | 6 +-
.../src/airflow/providers/singularity/__init__.py | 2 +-
.../providers/singularity/get_provider_info.py | 3 +-
providers/slack/README.rst | 6 +-
providers/slack/docs/changelog.rst | 15 +
providers/slack/docs/commits.rst | 18 +-
providers/slack/docs/index.rst | 6 +-
providers/slack/provider.yaml | 3 +-
providers/slack/pyproject.toml | 6 +-
.../slack/src/airflow/providers/slack/__init__.py | 2 +-
.../airflow/providers/slack/get_provider_info.py | 3 +-
providers/smtp/README.rst | 6 +-
providers/smtp/docs/changelog.rst | 15 +
providers/smtp/docs/commits.rst | 18 +-
providers/smtp/docs/index.rst | 2 +-
providers/smtp/provider.yaml | 3 +-
providers/smtp/pyproject.toml | 6 +-
.../smtp/src/airflow/providers/smtp/__init__.py | 2 +-
.../airflow/providers/smtp/get_provider_info.py | 3 +-
providers/snowflake/README.rst | 6 +-
providers/snowflake/docs/changelog.rst | 22 +
providers/snowflake/docs/commits.rst | 21 +-
providers/snowflake/docs/index.rst | 6 +-
providers/snowflake/provider.yaml | 3 +-
providers/snowflake/pyproject.toml | 6 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
.../providers/snowflake/get_provider_info.py | 3 +-
providers/sqlite/README.rst | 6 +-
providers/sqlite/docs/changelog.rst | 20 +
providers/sqlite/docs/commits.rst | 634 +-
providers/sqlite/docs/index.rst | 6 +-
providers/sqlite/provider.yaml | 3 +-
providers/sqlite/pyproject.toml | 6 +-
.../src/airflow/providers/sqlite/__init__.py | 2 +-
.../airflow/providers/sqlite/get_provider_info.py | 3 +-
providers/ssh/README.rst | 6 +-
providers/ssh/docs/changelog.rst | 25 +
providers/ssh/docs/commits.rst | 803 +-
providers/ssh/docs/connections/ssh.rst | 2 +-
providers/ssh/docs/index.rst | 2 +-
providers/ssh/provider.yaml | 3 +-
providers/ssh/pyproject.toml | 6 +-
.../ssh/src/airflow/providers/ssh/__init__.py | 2 +-
.../src/airflow/providers/ssh/get_provider_info.py | 3 +-
providers/standard/README.rst | 6 +-
providers/standard/docs/changelog.rst | 22 +
providers/standard/docs/commits.rst | 25 +-
providers/standard/docs/index.rst | 2 +-
providers/standard/provider.yaml | 5 +-
providers/standard/pyproject.toml | 6 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
.../providers/standard/get_provider_info.py | 5 +-
.../airflow/providers/standard/operators/python.py | 8 +-
.../providers/standard}/operators/smooth.py | 2 +-
.../providers/standard/operators/trigger_dagrun.py | 7 +-
.../providers/standard/sensors/external_task.py | 7 +-
.../tests/unit/standard/operators/test_smooth.py | 21 +-
providers/tableau/README.rst | 6 +-
providers/tableau/docs/changelog.rst | 15 +
providers/tableau/docs/commits.rst | 18 +-
providers/tableau/docs/index.rst | 2 +-
providers/tableau/provider.yaml | 3 +-
providers/tableau/pyproject.toml | 6 +-
.../src/airflow/providers/tableau/__init__.py | 2 +-
.../airflow/providers/tableau/get_provider_info.py | 3 +-
providers/telegram/README.rst | 6 +-
providers/telegram/docs/changelog.rst | 15 +
providers/telegram/docs/commits.rst | 18 +-
providers/telegram/docs/index.rst | 2 +-
providers/telegram/provider.yaml | 3 +-
providers/telegram/pyproject.toml | 6 +-
.../src/airflow/providers/telegram/__init__.py | 2 +-
.../providers/telegram/get_provider_info.py | 3 +-
providers/teradata/README.rst | 6 +-
providers/teradata/docs/changelog.rst | 20 +
providers/teradata/docs/commits.rst | 19 +-
providers/teradata/docs/index.rst | 6 +-
providers/teradata/provider.yaml | 3 +-
providers/teradata/pyproject.toml | 6 +-
.../src/airflow/providers/teradata/__init__.py | 2 +-
.../providers/teradata/get_provider_info.py | 3 +-
providers/trino/README.rst | 6 +-
providers/trino/docs/changelog.rst | 21 +
providers/trino/docs/commits.rst | 20 +-
providers/trino/docs/index.rst | 6 +-
providers/trino/provider.yaml | 3 +-
providers/trino/pyproject.toml | 6 +-
.../trino/src/airflow/providers/trino/__init__.py | 2 +-
.../airflow/providers/trino/get_provider_info.py | 3 +-
providers/vertica/README.rst | 6 +-
providers/vertica/docs/changelog.rst | 27 +
providers/vertica/docs/commits.rst | 579 +-
providers/vertica/docs/index.rst | 6 +-
providers/vertica/provider.yaml | 3 +-
providers/vertica/pyproject.toml | 6 +-
.../src/airflow/providers/vertica/__init__.py | 2 +-
.../airflow/providers/vertica/get_provider_info.py | 3 +-
providers/weaviate/README.rst | 6 +-
providers/weaviate/docs/changelog.rst | 15 +
providers/weaviate/docs/commits.rst | 18 +-
providers/weaviate/docs/index.rst | 2 +-
providers/weaviate/provider.yaml | 3 +-
providers/weaviate/pyproject.toml | 6 +-
.../src/airflow/providers/weaviate/__init__.py | 2 +-
.../providers/weaviate/get_provider_info.py | 3 +-
providers/yandex/README.rst | 25 +-
providers/yandex/docs/changelog.rst | 18 +
providers/yandex/docs/commits.rst | 21 +-
providers/yandex/docs/index.rst | 30 +-
providers/yandex/provider.yaml | 3 +-
providers/yandex/pyproject.toml | 14 +-
.../src/airflow/providers/yandex/__init__.py | 2 +-
.../airflow/providers/yandex/get_provider_info.py | 4 +-
.../src/airflow/providers/yandex/links/yq.py | 9 +-
providers/ydb/README.rst | 6 +-
providers/ydb/docs/changelog.rst | 28 +
providers/ydb/docs/commits.rst | 128 +-
providers/ydb/docs/index.rst | 6 +-
providers/ydb/provider.yaml | 3 +-
providers/ydb/pyproject.toml | 6 +-
.../ydb/src/airflow/providers/ydb/__init__.py | 2 +-
.../src/airflow/providers/ydb/get_provider_info.py | 4 +-
providers/zendesk/README.rst | 6 +-
providers/zendesk/docs/changelog.rst | 20 +
providers/zendesk/docs/commits.rst | 482 +-
providers/zendesk/docs/index.rst | 2 +-
providers/zendesk/provider.yaml | 3 +-
providers/zendesk/pyproject.toml | 6 +-
.../src/airflow/providers/zendesk/__init__.py | 2 +-
.../airflow/providers/zendesk/get_provider_info.py | 3 +-
pyproject.toml | 7 -
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/kubernetes/k8s_requirements.txt | 1 +
scripts/ci/pre_commit/check_google_re2_imports.py | 93 -
.../check_providers_subpackages_all_have_init.py | 1 +
.../ci/pre_commit/check_tests_in_right_folders.py | 1 -
scripts/ci/pre_commit/compile_ui_assets.py | 4 +-
scripts/ci/pre_commit/compile_ui_assets_dev.py | 4 +-
scripts/ci/pre_commit/version_heads_map.py | 9 +-
scripts/cov/other_coverage.py | 1 -
scripts/cov/restapi_coverage.py | 11 +-
scripts/in_container/run_migration_reference.py | 15 +-
.../in_container/run_update_fastapi_api_spec.py | 20 +-
scripts/tools/setup_breeze | 2 +-
task-sdk/pyproject.toml | 1 -
task-sdk/src/airflow/sdk/__init__.py | 3 +
.../sdk/definitions/_internal/abstractoperator.py | 2 +-
.../src/airflow/sdk/definitions/_internal/node.py | 5 +-
.../src/airflow/sdk/definitions/asset/__init__.py | 102 +-
.../airflow/sdk/definitions/asset/decorators.py | 25 +-
.../src/airflow/sdk/definitions/baseoperator.py | 62 +-
.../airflow/sdk/definitions}/baseoperatorlink.py | 0
task-sdk/src/airflow/sdk/definitions/dag.py | 13 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 2 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 8 +-
.../airflow/sdk/execution_time/secrets_masker.py | 7 +-
.../src/airflow/sdk/execution_time/task_runner.py | 13 +-
task-sdk/tests/task_sdk/definitions/test_asset.py | 156 +-
.../task_sdk/definitions/test_asset_decorators.py | 25 +
.../task_sdk/definitions/test_baseoperator.py | 84 +-
.../task_sdk/definitions/test_secrets_masker.py | 4 +-
.../task_sdk/execution_time/test_task_runner.py | 17 +-
tests/always/test_project_structure.py | 1 +
.../schemas => tests/api_fastapi/auth}/__init__.py | 0
.../api_fastapi/auth/managers}/__init__.py | 0
.../api_fastapi/auth/managers/simple}/__init__.py | 0
.../auth/managers/simple/conftest.py | 26 +-
.../auth/managers/simple/routes}/__init__.py | 0
.../auth/managers/simple/routes/test_login.py | 27 +-
.../auth/managers/simple/services}/__init__.py | 0
.../auth/managers/simple/services/test_login.py | 6 +-
.../managers/simple/test_simple_auth_manager.py | 21 +-
.../auth/managers/simple/test_user.py | 0
.../auth/managers/test_base_auth_manager.py | 34 +-
tests/api_fastapi/conftest.py | 8 +-
.../core_api/routes/public/test_config.py | 20 +
.../core_api/routes/public/test_dags.py | 92 +-
.../core_api/routes/public/test_extra_links.py | 14 +
.../api_fastapi/core_api/routes/public/test_job.py | 8 +
.../api_fastapi/core_api/routes/public/test_log.py | 14 +
.../core_api/routes/public/test_login.py | 21 +-
.../core_api/routes/public/test_plugins.py | 10 +-
.../core_api/routes/public/test_pools.py | 6 +
.../core_api/routes/public/test_providers.py | 10 +-
.../core_api/routes/public/test_task_instances.py | 4 +
.../api_fastapi/core_api/routes/ui/test_assets.py | 57 +-
.../api_fastapi/core_api/routes/ui/test_config.py | 24 +-
tests/api_fastapi/core_api/routes/ui/test_grid.py | 135 +-
tests/api_fastapi/core_api/test_security.py | 44 +-
tests/assets/test_evaluation.py | 199 +
tests/auth/__init__.py | 16 -
tests/auth/managers/__init__.py | 16 -
tests/auth/managers/simple/__init__.py | 16 -
tests/auth/managers/simple/routes/__init__.py | 16 -
tests/auth/managers/simple/services/__init__.py | 16 -
.../local_commands/test_plugins_command.py | 2 +-
.../commands/remote_commands/test_dag_command.py | 5 +-
.../commands/remote_commands/test_task_command.py | 558 +-
tests/dag_processing/test_collection.py | 10 +-
tests/dag_processing/test_manager.py | 3 +
tests/dags/test_dags_folder.py | 38 -
tests/jobs/test_local_task_job.py | 1027 -
tests/jobs/test_scheduler_job.py | 5 +-
tests/models/test_asset.py | 4 +-
tests/models/test_baseoperatormeta.py | 224 -
tests/models/test_dag.py | 6 +-
tests/models/test_taskinstance.py | 13 +-
tests/sensors/test_external_task_sensor.py | 4 +-
tests/serialization/test_dag_serialization.py | 2 +-
tests/task/test_standard_task_runner.py | 547 -
tests/timetables/test_assets_timetable.py | 5 +-
tests/utils/test_cli_util.py | 4 +-
tests/utils/test_task_group.py | 2 +-
1150 files changed, 23411 insertions(+), 32066 deletions(-)
delete mode 100644 airflow/api_connexion/schemas/dag_schema.py
rename airflow/{ => api_fastapi}/auth/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/base_auth_manager.py (91%)
rename airflow/{ => api_fastapi}/auth/managers/models/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/models/base_user.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/models/batch_apis.py (92%)
rename airflow/{ => api_fastapi}/auth/managers/models/resource_details.py (95%)
rename airflow/{ => api_fastapi}/auth/managers/simple/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/datamodels/__init__.py
(100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/datamodels/login.py
(100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/openapi/__init__.py
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/openapi/v1-generated.yaml (87%)
rename airflow/{ => api_fastapi}/auth/managers/simple/routes/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/routes/login.py (58%)
copy airflow/{api_connexion =>
api_fastapi/auth/managers/simple/services}/__init__.py (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/services/login.py (88%)
rename airflow/{ => api_fastapi}/auth/managers/simple/simple_auth_manager.py
(87%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/dev/index.html (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/index.html (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/common.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/index.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/infiniteQueries.ts
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/prefetch.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/queries.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/queries/suspense.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/ApiError.ts
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/ApiRequestOptions.ts
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/ApiResult.ts
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/CancelablePromise.ts
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/OpenAPI.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/core/request.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/index.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/schemas.gen.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/services.gen.ts (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/openapi-gen/requests/types.gen.ts (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/package-lock.json
(93%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/package.json (93%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/pnpm-lock.yaml (83%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/src/login/Login.test.tsx (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/src/login/Login.tsx
(100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/src/login/LoginForm.tsx (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/src/main.tsx (100%)
rename airflow/{ =>
api_fastapi}/auth/managers/simple/ui/src/queries/useCreateToken.ts (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/src/queryClient.ts
(100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/src/router.tsx (97%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/src/test-utils.tsx
(100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/tests-setup.ts (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/ui/vite.config.ts (100%)
rename airflow/{ => api_fastapi}/auth/managers/simple/user.py (95%)
create mode 100644 airflow/assets/evaluation.py
delete mode 100644 airflow/auth/managers/utils/__init__.py
delete mode 100644 airflow/auth/managers/utils/fab.py
copy airflow/example_dags/{example_bash_operator.py =>
example_custom_weight.py} (52%)
delete mode 100644 airflow/jobs/local_task_job_runner.py
create mode 100644
airflow/migrations/versions/0061_3_0_0_use_ti_id_as_primary_key_to_TINote.py
copy airflow/migrations/versions/{0056_3_0_0_add_relative_fileloc_column.py =>
0062_3_0_0_remove_dag_default_view.py} (72%)
delete mode 100644 airflow/task/standard_task_runner.py
rename airflow/ui/src/{layouts/BaseLayout.test.tsx =>
utils/tokenHandler.test.ts} (71%)
copy providers/fab/src/airflow/providers/fab/www/static/css/loading-dots.css
=> airflow/ui/src/utils/tokenHandler.ts (52%)
create mode 100644 chart/newsfragments/47416.significant.rst
create mode 100644 docs/apache-airflow/img/trigger-dag-tutorial-form-1.png
create mode 100644 docs/apache-airflow/img/trigger-dag-tutorial-form-2.png
create mode 100644 docs/apache-airflow/img/trigger-dag-tutorial-form-3.png
create mode 100644 docs/apache-airflow/img/trigger-dag-tutorial-form-4.png
delete mode 100644 docs/apache-airflow/img/trigger-dag-tutorial-form.png
copy providers/{amazon/src/airflow/providers/amazon =>
dbt/cloud/src/airflow/providers/dbt/cloud}/version_compat.py (100%)
copy providers/fab/src/airflow/providers/fab/www/static/css/{loading-dots.css
=> flash.css} (56%)
delete mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/d3-tip.js
copy airflow/ui/rules/levels.js =>
providers/fab/src/airflow/providers/fab/www/static/dist/flash.137b30cff85b5588e661.css
(64%)
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/flash.137b30cff85b5588e661.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/jquery-ui.min.css
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/jquery-ui.min.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/jquery-ui.min.js.LICENSE.txt
rename
providers/fab/src/airflow/providers/fab/www/static/dist/{main.b585926afc96bd076c4f.css
=> main.ec1d38d994d72bb083cd.css} (100%)
rename
providers/fab/src/airflow/providers/fab/www/static/dist/{main.b585926afc96bd076c4f.js
=> main.ec1d38d994d72bb083cd.js} (98%)
rename
providers/fab/src/airflow/providers/fab/www/static/dist/{main.b585926afc96bd076c4f.js.LICENSE.txt
=> main.ec1d38d994d72bb083cd.js.LICENSE.txt} (100%)
copy docs/exts/templates/deprecations.rst.jinja2 =>
providers/fab/src/airflow/providers/fab/www/templates/appbuilder/flash.html
(55%)
copy
providers/google/tests/system/google/cloud/dataflow/{example_dataflow_native_java.py
=> example_dataflow_java_streaming.py} (52%)
create mode 100644
providers/google/tests/system/google/cloud/dataflow/resources/non_python_src/java_streaming_src/README.MD
create mode 100644
providers/google/tests/system/google/cloud/dataflow/resources/non_python_src/java_streaming_src/pom.xml
create mode 100644
providers/google/tests/system/google/cloud/dataflow/resources/non_python_src/java_streaming_src/src/main/java/org/example/pubsub/StreamingExample.java
rename {airflow =>
providers/standard/src/airflow/providers/standard}/operators/smooth.py (93%)
copy airflow/api_fastapi/common/db/dag_runs.py =>
providers/standard/tests/unit/standard/operators/test_smooth.py (68%)
delete mode 100755 scripts/ci/pre_commit/check_google_re2_imports.py
rename {airflow/models =>
task-sdk/src/airflow/sdk/definitions}/baseoperatorlink.py (100%)
rename {airflow/api_connexion/schemas => tests/api_fastapi/auth}/__init__.py
(100%)
rename {airflow/auth/managers/simple/services =>
tests/api_fastapi/auth/managers}/__init__.py (100%)
copy {airflow/api_connexion =>
tests/api_fastapi/auth/managers/simple}/__init__.py (100%)
rename tests/{ => api_fastapi}/auth/managers/simple/conftest.py (60%)
copy {airflow/api_connexion =>
tests/api_fastapi/auth/managers/simple/routes}/__init__.py (100%)
rename tests/{ => api_fastapi}/auth/managers/simple/routes/test_login.py (72%)
rename {airflow/api_connexion =>
tests/api_fastapi/auth/managers/simple/services}/__init__.py (100%)
rename tests/{ => api_fastapi}/auth/managers/simple/services/test_login.py
(90%)
rename tests/{ =>
api_fastapi}/auth/managers/simple/test_simple_auth_manager.py (88%)
rename tests/{ => api_fastapi}/auth/managers/simple/test_user.py (100%)
rename tests/{ => api_fastapi}/auth/managers/test_base_auth_manager.py (89%)
create mode 100644 tests/assets/test_evaluation.py
delete mode 100644 tests/auth/__init__.py
delete mode 100644 tests/auth/managers/__init__.py
delete mode 100644 tests/auth/managers/simple/__init__.py
delete mode 100644 tests/auth/managers/simple/routes/__init__.py
delete mode 100644 tests/auth/managers/simple/services/__init__.py
delete mode 100644 tests/dags/test_dags_folder.py
delete mode 100644 tests/jobs/test_local_task_job.py
delete mode 100644 tests/models/test_baseoperatormeta.py
delete mode 100644 tests/task/test_standard_task_runner.py