This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch move-first-provider-to-separate-project
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit abbab3efb88 mOve first provider (airbyte) to a separate project
add 413a1833c30 Fix HTTP 500 error on updating same task instance state
via FastAPI PATCH taskinstance/{task} endpoint (#45288)
add f03b1d4d996 docs: clarify which fields are masked in the UI (#45417)
add 9ba279d15f2 Remove scheduler automate serviceaccount token (#44173)
add f0b276fbab7 AIP-38 Improve clear dagrun table display for long task
display names (#45437)
add 5581e65fd55 Bump trove-classifiers from 2024.10.21.16 to 2025.1.6.15
(#45439)
add 1208679cd8a Switch to single key for bundle config (#45318)
add 8639ade6451 Restrict marshmallow==3.24 (#45442)
add a6da8df0d7b AIP-72: Allow retrieving Variable from Task Context
(#45431)
add 972714e9cdb Add tests cases for multiple executors in chart (#44424)
add b2a244bb135 AIP-72: Add Taskflow API support & template rendering in
Task SDK (#45444)
add 4b90edf580b Move update subscription from
`AzureServiceBusTopicCreateOperator` to `AdminClientHook` (#45367)
add 0cc2d724d15 Add MessageDeduplicationId support to AWS
SqsPublishOperator (#45051)
add c14494609d8 Minor query fix changing session.execute to
session.scalars (#45460)
add 4ab8e5ec96c AIP-38 Ability to update note when clearing a DagRun
(#45434)
add 228127036a8 Deprecate page_size parameter for Google Ads API v17 and
later versions (#45239)
add a2d8eb2345e Cleanup some useless mocks/fixture in manager tests
(#45340)
add 5bc5dc08537 Do not use core Airflow Flask related resources in FAB
provider (#45441)
add 2cf9eb456a8 fix deserializing callbacks to proper types (#45305)
add c2ab839aa54 AIP-72: Exposing 'extra_dejson' on Connection definition
(#45448)
add df1657283b2 Default tooltips to showArrow (#45468)
add 1dcc29a2eff Semantically correct the TI state handling in supervisor
(#45291)
add 4c5d85aeec5 feat: Add OpenLineage support for some BQ operators
(#45422)
add 03993819690 Support Task execution interface (AIP-72) in Airflow 3 in
EdgeExecutor (#44982)
add 6b66479785b Bump trove-classifiers from 2025.1.6.15 to 2025.1.7.14
(#45467)
add 37878446939 Fixing return type for azure hook 'run_query' (#45470)
add 301017de2d7 refactor: Updated instantiated of httpx AsyncClient as the
proxies parameter is deprecated and mounts parameter should be used instead
(#45464)
add c300e0e7c6b AIP-81 Implement Create Default Connections Endpoint in
REST API (FastAPI) (#45363)
add a2492dde3fe do not instantiate raw CallbackRequest (#45482)
add 8ae1ef0c7a7 Add full screen view for logs (#45183)
add 06350716d6d Add grid data to graph (#44854)
add dc3111aa8d2 Fix `fetch_access_token_for_cluster` in EKS hook (#45469)
add 185573ecd89 update reset_dag_runs default value to true (#45453)
add 32dc9e83791 Do not use core Airflow Flask related resources in FAB
provider (package `api_connexion`) (#45473)
add 3fc73229da6 AIP-38 Fix markdown rendering due to ChakraUI CSS reset
(#45459)
add 97b4ea6128e Prevent new pytest-asyncio from failing our tests (#45477)
add a2838418915 Do not use core Airflow Flask related resources in FAB
provider (package `security`) (#45471)
add ab730b1b5fa feat: Add OpenLineage support for some SQL to GCS
operators (#45242)
add 39d7f1cae6c Add dags search widget to navbar for quick search (#45198)
add adbe4e256e6 Add view_url for DagBundles (#45126)
add 68c7f895749 Implement AlloyDB create/update/delete user and backups
operators (#45378)
add 1f56cfc6917 add case of aarch64 environments (#45488)
add 42f513e891e feat: Add OpenLineage support for transfer operators
between GCS and SFTP (#45485)
add c2feef6273a Remove marshmallow version restriction; update deprecated
usages (#45499)
add b703d53b774 Move Literal alias into TYPE_CHECKING block (#45345)
add 04806231e44 AIP-72: Add support for `get_current_context` in Task SDK
(#45486)
add 9de80ab8f76 AIP-72: Add logging for exception in Task Runner (#45502)
add 92c72dbd9b7 AIP-72: Remove redundant handling of `AirflowException`
(#45505)
add 9bd2dbb20e0 Move first provider (airbyte) to a separate project
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 (abbab3efb88)
\
N -- N -- N refs/heads/move-first-provider-to-separate-project
(9bd2dbb20e0)
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:
airflow/api_connexion/schemas/task_schema.py | 6 +-
airflow/api_fastapi/app.py | 5 +-
.../core_api/datamodels/task_instances.py | 2 +-
.../api_fastapi/core_api/openapi/v1-generated.yaml | 36 +-
.../core_api/routes/public/connections.py | 12 +
.../core_api/routes/public/task_instances.py | 14 +-
airflow/api_fastapi/core_api/security.py | 6 +-
airflow/auth/managers/base_auth_manager.py | 66 +-
.../auth/managers/simple/simple_auth_manager.py | 8 +-
airflow/callbacks/callback_requests.py | 18 +-
.../cli/commands/remote_commands/task_command.py | 12 +-
airflow/config_templates/config.yml | 54 +-
airflow/configuration.py | 4 +
airflow/dag_processing/bundles/base.py | 8 +
airflow/dag_processing/bundles/git.py | 29 +
airflow/dag_processing/bundles/manager.py | 97 +-
airflow/dag_processing/manager.py | 4 +-
airflow/dag_processing/processor.py | 3 +-
airflow/decorators/base.py | 2 +-
airflow/executors/base_executor.py | 4 +-
airflow/executors/local_executor.py | 6 +-
airflow/jobs/scheduler_job_runner.py | 2 +-
airflow/macros/__init__.py | 44 +-
airflow/models/abstractoperator.py | 78 +-
airflow/models/baseoperator.py | 18 -
airflow/models/expandinput.py | 13 +-
airflow/models/mappedoperator.py | 8 +-
airflow/models/param.py | 7 +-
airflow/models/serialized_dag.py | 4 +-
airflow/models/taskinstance.py | 4 +-
airflow/models/xcom_arg.py | 27 +-
airflow/notifications/basenotifier.py | 5 +-
airflow/providers_manager.py | 4 +-
airflow/templates.py | 94 --
airflow/ui/openapi-gen/queries/common.ts | 3 +
airflow/ui/openapi-gen/queries/queries.ts | 17 +
airflow/ui/openapi-gen/requests/schemas.gen.ts | 2 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 20 +
airflow/ui/openapi-gen/requests/types.gen.ts | 28 +
airflow/ui/package.json | 2 +
airflow/ui/pnpm-lock.yaml | 16 +
airflow/ui/rules/react.js | 2 +-
.../ui/src/components/ClearRun/ClearRunButton.tsx | 13 +-
.../ui/src/components/ClearRun/ClearRunDialog.tsx | 29 +-
.../components/ClearRun/ClearRunTaskAccordion.tsx | 68 +-
airflow/ui/src/components/DagRunInfo.tsx | 1 -
airflow/ui/src/components/DocumentationModal.tsx | 6 +-
airflow/ui/src/components/ReactMarkdown.tsx | 117 +++
.../ui/src/components/SearchDags/SearchDags.tsx | 96 ++
.../Status.tsx => SearchDags/SearchDagsButton.tsx} | 37 +-
.../SearchDags/SearchDagsDropdownIndicator.tsx} | 16 +-
.../SearchDags/index.ts} | 11 +-
airflow/ui/src/components/TaskInstanceTooltip.tsx | 72 +-
airflow/ui/src/components/ui/Status.tsx | 4 +-
airflow/ui/src/components/ui/Tooltip.tsx | 11 +-
airflow/ui/src/layouts/Details/DagRunSelect.tsx | 92 ++
airflow/ui/src/layouts/Details/DagVizModal.tsx | 16 +-
airflow/ui/src/layouts/Details/DetailsLayout.tsx | 18 +-
airflow/ui/src/layouts/Details/Graph/Edge.tsx | 4 +-
airflow/ui/src/layouts/Details/Graph/Graph.tsx | 96 +-
airflow/ui/src/layouts/Details/Graph/JoinNode.tsx | 7 +-
airflow/ui/src/layouts/Details/Graph/TaskName.tsx | 51 +-
airflow/ui/src/layouts/Details/Graph/TaskNode.tsx | 106 +-
.../ui/src/layouts/Details/Graph/reactflowUtils.ts | 11 +-
.../ui/src/layouts/Details/Graph/useGraphLayout.ts | 13 +-
airflow/ui/src/pages/Dag/Header.tsx | 2 +-
airflow/ui/src/pages/Dag/Runs/Runs.tsx | 2 +-
airflow/ui/src/pages/DagsList/DagCard.tsx | 2 +-
airflow/ui/src/pages/DagsList/DagTags.tsx | 1 -
airflow/ui/src/pages/DagsList/RecentRuns.tsx | 1 -
airflow/ui/src/pages/DagsList/Schedule.tsx | 2 +-
.../src/pages/Dashboard/Health/HealthSection.tsx | 1 -
.../ui/src/pages/Dashboard/Health/HealthTag.tsx | 1 -
airflow/ui/src/pages/Run/Header.tsx | 2 +-
.../ui/src/pages/TaskInstance/{ => Logs}/Logs.tsx | 78 +-
.../Logs/TaskLogContent.tsx} | 32 +-
.../src/pages/TaskInstance/Logs/TaskLogHeader.tsx | 66 ++
.../TaskInstance/Logs/index.ts} | 11 +-
airflow/ui/src/queries/useClearRun.ts | 2 +-
airflow/ui/src/queries/usePatchDagRun.ts | 49 +
airflow/ui/src/utils/TrimText.tsx | 4 +-
.../Graph/JoinNode.tsx => utils/trimTextFn.ts} | 13 +-
airflow/utils/context.py | 6 +-
airflow/utils/context.pyi | 2 +-
airflow/utils/mixins.py | 27 -
airflow/www/extensions/init_appbuilder.py | 6 +-
chart/templates/rbac/pod-launcher-rolebinding.yaml | 19 +-
.../scheduler/scheduler-serviceaccount.yaml | 2 +
chart/templates/workers/worker-hpa.yaml | 2 +-
chart/values.yaml | 2 +-
.../tests/test_pytest_args_for_test_types.py | 1 -
.../edge_executor.rst | 7 +-
.../operators/cloud/alloy_db.rst | 89 ++
.../security/secrets/mask-sensitive-values.rst | 6 +-
docs/exts/includes/sections-and-options.rst | 21 +-
generated/provider_dependencies.json | 4 +-
hatch_build.py | 4 +-
helm_tests/airflow_aux/test_configmap.py | 2 +
helm_tests/airflow_aux/test_pod_launcher_role.py | 1 +
helm_tests/airflow_core/test_scheduler.py | 47 +-
helm_tests/airflow_core/test_worker.py | 1 +
helm_tests/other/test_flower.py | 2 +
helm_tests/other/test_hpa.py | 5 +-
helm_tests/other/test_keda.py | 7 +-
helm_tests/other/test_redis.py | 2 +-
kubernetes_tests/test_kubernetes_pod_operator.py | 2 +
newsfragments/aip-79.significant.rst | 4 +
.../amazon/aws/auth_manager/aws_auth_manager.py | 7 +-
.../amazon/aws/executors/ecs/boto_schema.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/eks.py | 5 +-
.../src/airflow/providers/amazon/aws/hooks/sqs.py | 4 +
.../airflow/providers/amazon/aws/operators/sqs.py | 6 +
.../airflow/providers/amazon/aws/sensors/sqs.py | 3 +-
.../airflow/providers/amazon/aws/triggers/sqs.py | 3 +-
.../src/airflow/providers/amazon/aws/utils/sqs.py | 10 +-
.../airflow/providers/common/compat/__init__.py | 2 +-
.../common/compat/openlineage/utils/sql.py | 84 ++
.../airflow/providers/common/compat/provider.yaml | 1 +
.../airflow/providers/docker/decorators/docker.py | 4 +-
providers/src/airflow/providers/edge/CHANGELOG.rst | 14 +-
providers/src/airflow/providers/edge/__init__.py | 2 +-
.../src/airflow/providers/edge/cli/edge_command.py | 104 +-
.../providers/edge/executors/edge_executor.py | 30 +-
providers/src/airflow/providers/edge/provider.yaml | 2 +-
.../src/airflow/providers/edge/worker_api/auth.py | 5 +-
.../providers/edge/worker_api/datamodels.py | 8 +-
.../providers/edge/worker_api/routes/_v2_compat.py | 15 +
.../providers/edge/worker_api/routes/jobs.py | 4 +-
.../auth_manager/api/auth/backend/basic_auth.py | 4 +-
.../auth_manager/api/auth/backend/kerberos_auth.py | 4 +-
.../api_endpoints/role_and_permission_endpoint.py | 25 +-
.../auth_manager/api_endpoints/user_endpoint.py | 22 +-
.../fab/auth_manager/cli_commands/utils.py | 10 +-
.../providers/fab/auth_manager/decorators/auth.py | 127 ---
.../providers/fab/auth_manager/fab_auth_manager.py | 41 +-
.../fab/auth_manager/schemas/user_schema.py | 2 +-
.../fab/auth_manager/security_manager/override.py | 13 +-
.../fab/auth_manager/views/permissions.py | 2 +-
.../providers/fab/auth_manager/views/roles_list.py | 2 +-
.../providers/fab/auth_manager/views/user.py | 2 +-
.../providers/fab/auth_manager/views/user_edit.py | 2 +-
.../providers/fab/auth_manager/views/user_stats.py | 2 +-
.../decorators => www/api_connexion}/__init__.py | 0
.../providers/fab/www}/api_connexion/exceptions.py | 0
.../providers/fab/www/api_connexion/parameters.py | 131 +++
.../providers/fab/www/api_connexion/security.py | 82 ++
.../providers/fab/www}/api_connexion/types.py | 0
providers/src/airflow/providers/fab/www/app.py | 3 +-
.../src/airflow/providers/fab}/www/constants.py | 0
.../fab/www/extensions/init_appbuilder.py | 11 +-
.../providers/fab/www/extensions/init_security.py | 17 +
.../providers/fab/www/extensions/init_session.py | 64 ++
.../providers/fab/www/extensions/init_views.py | 55 +-
.../providers/fab/www/security}/__init__.py | 0
.../providers/fab/www}/security/permissions.py | 0
.../airflow/providers/fab/www/security_manager.py | 310 ++++++
.../src/airflow/providers/fab}/www/session.py | 0
providers/src/airflow/providers/fab/www/utils.py | 229 +++++
providers/src/airflow/providers/fab/www/views.py | 66 ++
.../src/airflow/providers/google/ads/hooks/ads.py | 35 +-
.../providers/google/ads/transfers/ads_to_gcs.py | 22 +-
.../providers/google/cloud/hooks/alloy_db.py | 429 ++++++++-
.../providers/google/cloud/hooks/cloud_sql.py | 2 +
.../providers/google/cloud/links/alloy_db.py | 46 +
.../providers/google/cloud/operators/alloy_db.py | 599 +++++++++++-
.../providers/google/cloud/operators/bigquery.py | 165 +++-
.../google/cloud/transfers/gcs_to_sftp.py | 40 +-
.../google/cloud/transfers/mysql_to_gcs.py | 29 +-
.../google/cloud/transfers/postgres_to_gcs.py | 29 +-
.../google/cloud/transfers/sftp_to_gcs.py | 39 +-
.../providers/google/cloud/transfers/sql_to_gcs.py | 15 +
.../google/cloud/transfers/trino_to_gcs.py | 27 +-
.../src/airflow/providers/google/provider.yaml | 4 +-
.../airflow/providers/microsoft/azure/hooks/adx.py | 8 +-
.../airflow/providers/microsoft/azure/hooks/asb.py | 33 +
.../providers/microsoft/azure/hooks/msgraph.py | 2 +-
.../providers/microsoft/azure/operators/asb.py | 19 +-
.../airflow/providers/openlineage/provider.yaml | 2 +-
.../src/airflow/providers/openlineage/sqlparser.py | 39 +
.../airflow/providers/standard/operators/python.py | 31 +-
.../providers/standard/utils/python_virtualenv.py | 5 +-
.../airflow/providers/weaviate/hooks/weaviate.py | 2 +-
providers/tests/amazon/aws/hooks/test_eks.py | 4 +
providers/tests/amazon/aws/operators/test_sqs.py | 31 +-
.../executors/test_celery_kubernetes_executor.py | 9 +-
.../executors/test_local_kubernetes_executor.py | 9 +-
.../kubernetes/operators/test_spark_kubernetes.py | 12 +-
providers/tests/edge/cli/test_edge_command.py | 57 +-
.../tests/edge/executors/test_edge_executor.py | 42 +
.../edge/plugins/test_edge_executor_plugin.py | 6 +-
.../api_endpoints/test_asset_endpoint.py | 4 +-
.../api_endpoints/test_dag_endpoint.py | 4 +-
.../api_endpoints/test_dag_run_endpoint.py | 2 +-
.../api_endpoints/test_dag_source_endpoint.py | 2 +-
.../api_endpoints/test_dag_warning_endpoint.py | 2 +-
.../api_endpoints/test_event_log_endpoint.py | 2 +-
.../api_endpoints/test_import_error_endpoint.py | 2 +-
.../test_role_and_permission_endpoint.py | 4 +-
.../api_endpoints/test_task_instance_endpoint.py | 4 +-
.../api_endpoints/test_user_endpoint.py | 4 +-
.../api_endpoints/test_variable_endpoint.py | 2 +-
.../api_endpoints/test_xcom_endpoint.py | 2 +-
.../auth_manager/cli_commands/test_role_command.py | 2 +-
.../fab/auth_manager/cli_commands/test_utils.py | 4 +-
.../tests/fab/auth_manager/decorators/__init__.py | 16 -
.../tests/fab/auth_manager/decorators/test_auth.py | 161 ----
.../schemas/test_role_and_permission_schema.py | 2 +-
.../fab/auth_manager/test_fab_auth_manager.py | 78 +-
providers/tests/fab/auth_manager/test_security.py | 6 +-
.../fab/auth_manager/views/test_permissions.py | 2 +-
.../fab/auth_manager/views/test_roles_list.py | 2 +-
.../tests/fab/auth_manager/views/test_user.py | 2 +-
.../tests/fab/auth_manager/views/test_user_edit.py | 2 +-
.../fab/auth_manager/views/test_user_stats.py | 2 +-
providers/tests/google/ads/hooks/test_ads.py | 33 +-
providers/tests/google/ads/operators/test_ads.py | 2 +-
.../tests/google/ads/transfers/test_ads_to_gcs.py | 32 +
.../tests/google/cloud/hooks/test_alloy_db.py | 323 ++++++-
.../tests/google/cloud/links/test_alloy_db.py | 38 +-
.../tests/google/cloud/operators/test_alloy_db.py | 1013 ++++++++++++++++++++
.../tests/google/cloud/operators/test_bigquery.py | 168 ++++
.../google/cloud/transfers/test_gcs_to_sftp.py | 80 ++
.../google/cloud/transfers/test_mysql_to_gcs.py | 66 ++
.../google/cloud/transfers/test_postgres_to_gcs.py | 70 +-
.../google/cloud/transfers/test_sftp_to_gcs.py | 47 +
.../google/cloud/transfers/test_sql_to_gcs.py | 19 +
.../google/cloud/transfers/test_trino_to_gcs.py | 69 +-
providers/tests/microsoft/azure/hooks/test_asb.py | 31 +
.../tests/microsoft/azure/operators/test_asb.py | 27 +-
providers/tests/standard/operators/test_python.py | 6 +-
.../google/cloud/alloy_db/example_alloy_db.py | 99 ++
pyproject.toml | 2 +-
scripts/cov/other_coverage.py | 1 -
{airflow/api_connexion => task_sdk}/__init__.py | 0
task_sdk/src/airflow/sdk/__init__.py | 4 +
task_sdk/src/airflow/sdk/api/client.py | 15 +-
.../airflow/sdk/definitions/abstractoperator.py | 73 +-
.../src/airflow/sdk/definitions/baseoperator.py | 21 +-
task_sdk/src/airflow/sdk/definitions/connection.py | 18 +
.../src/airflow/sdk/definitions/contextmanager.py | 46 +-
task_sdk/src/airflow/sdk/definitions/dag.py | 6 +-
.../src/airflow/sdk/definitions/macros.py | 55 +-
task_sdk/src/airflow/sdk/definitions/mixins.py | 28 +-
.../src/airflow/sdk/definitions}/templater.py | 105 +-
.../src/airflow/sdk/definitions/variable.py | 21 +-
task_sdk/src/airflow/sdk/execution_time/comms.py | 2 +-
task_sdk/src/airflow/sdk/execution_time/context.py | 110 ++-
.../src/airflow/sdk/execution_time/supervisor.py | 21 +-
.../src/airflow/sdk/execution_time/task_runner.py | 136 ++-
task_sdk/tests/api/test_client.py | 36 +-
task_sdk/tests/defintions/test_baseoperator.py | 298 +++++-
.../test_contextmanager.py} | 33 +-
task_sdk/tests/defintions/test_macros.py | 72 ++
.../tests/defintions}/test_templater.py | 53 +-
task_sdk/tests/execution_time/conftest.py | 101 ++
task_sdk/tests/execution_time/test_context.py | 162 +++-
task_sdk/tests/execution_time/test_task_runner.py | 221 ++++-
.../core_api/routes/public/test_connections.py | 13 +
.../api_fastapi/core_api/routes/public/test_job.py | 22 +-
.../core_api/routes/public/test_task_instances.py | 18 +
tests/auth/managers/test_base_auth_manager.py | 88 +-
tests/callbacks/test_callback_requests.py | 2 -
.../remote_commands/test_config_command.py | 3 +-
tests/core/test_templates.py | 57 --
.../bundles/test_dag_bundle_manager.py | 136 +--
tests/dag_processing/test_dag_bundles.py | 35 +
tests/dag_processing/test_manager.py | 152 +--
tests/dag_processing/test_processor.py | 48 +
tests/macros/test_macros.py | 49 -
tests/models/test_baseoperator.py | 280 +-----
tests/models/test_dag.py | 2 +-
tests/template/__init__.py | 16 -
tests/www/test_security_manager.py | 4 +-
tests_common/_internals/capture_warnings.py | 9 +-
274 files changed, 8413 insertions(+), 2159 deletions(-)
delete mode 100644 airflow/templates.py
create mode 100644 airflow/ui/src/components/ReactMarkdown.tsx
create mode 100644 airflow/ui/src/components/SearchDags/SearchDags.tsx
copy airflow/ui/src/components/{ui/Status.tsx =>
SearchDags/SearchDagsButton.tsx} (53%)
copy airflow/ui/src/{layouts/Details/Graph/JoinNode.tsx =>
components/SearchDags/SearchDagsDropdownIndicator.tsx} (65%)
copy airflow/ui/src/{layouts/Details/Graph/JoinNode.tsx =>
components/SearchDags/index.ts} (64%)
create mode 100644 airflow/ui/src/layouts/Details/DagRunSelect.tsx
rename airflow/ui/src/pages/TaskInstance/{ => Logs}/Logs.tsx (57%)
copy airflow/ui/src/pages/{DagsList/Schedule.tsx =>
TaskInstance/Logs/TaskLogContent.tsx} (52%)
create mode 100644 airflow/ui/src/pages/TaskInstance/Logs/TaskLogHeader.tsx
copy airflow/ui/src/{layouts/Details/Graph/JoinNode.tsx =>
pages/TaskInstance/Logs/index.ts} (64%)
create mode 100644 airflow/ui/src/queries/usePatchDagRun.ts
copy airflow/ui/src/{layouts/Details/Graph/JoinNode.tsx =>
utils/trimTextFn.ts} (68%)
create mode 100644
providers/src/airflow/providers/common/compat/openlineage/utils/sql.py
delete mode 100644
providers/src/airflow/providers/fab/auth_manager/decorators/auth.py
rename providers/src/airflow/providers/fab/{auth_manager/decorators =>
www/api_connexion}/__init__.py (100%)
copy {airflow =>
providers/src/airflow/providers/fab/www}/api_connexion/exceptions.py (100%)
create mode 100644
providers/src/airflow/providers/fab/www/api_connexion/parameters.py
create mode 100644
providers/src/airflow/providers/fab/www/api_connexion/security.py
copy {airflow =>
providers/src/airflow/providers/fab/www}/api_connexion/types.py (100%)
copy {airflow => providers/src/airflow/providers/fab}/www/constants.py (100%)
create mode 100644
providers/src/airflow/providers/fab/www/extensions/init_session.py
copy {airflow/api/auth =>
providers/src/airflow/providers/fab/www/security}/__init__.py (100%)
copy {airflow =>
providers/src/airflow/providers/fab/www}/security/permissions.py (100%)
create mode 100644 providers/src/airflow/providers/fab/www/security_manager.py
copy {airflow => providers/src/airflow/providers/fab}/www/session.py (100%)
create mode 100644 providers/src/airflow/providers/fab/www/utils.py
create mode 100644 providers/src/airflow/providers/fab/www/views.py
delete mode 100644 providers/tests/fab/auth_manager/decorators/__init__.py
delete mode 100644 providers/tests/fab/auth_manager/decorators/test_auth.py
copy {airflow/api_connexion => task_sdk}/__init__.py (100%)
copy airflow/macros/__init__.py =>
task_sdk/src/airflow/sdk/definitions/macros.py (54%)
rename {airflow/template => task_sdk/src/airflow/sdk/definitions}/templater.py
(74%)
rename airflow/utils/template.py =>
task_sdk/src/airflow/sdk/definitions/variable.py (64%)
copy task_sdk/tests/{execution_time/conftest.py =>
defintions/test_contextmanager.py} (50%)
create mode 100644 task_sdk/tests/defintions/test_macros.py
rename {tests/template => task_sdk/tests/defintions}/test_templater.py (70%)
delete mode 100644 tests/core/test_templates.py
delete mode 100644 tests/template/__init__.py