This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch task-sdk-first-code
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard e87f6c4e70 [skip ci]
discard 6274cddac9 Get more tests passing
discard c718a153de fixup! Start porting over all the DAG defintion code to the
Task SDK
discard 22566d87f2 fixup! Start porting over all the DAG defintion code to the
Task SDK
discard 6fd0db289d fixup! Start porting over all the DAG defintion code to the
Task SDK
omit 74dd8f9b6c Start porting over all the DAG defintion code to the Task
SDK
add 39a16c0c4d Reorganize ``api_fastapi`` folder into apps (#43062)
add 75b22940ac Tweak AssetAlias to match Asset for AIP-74 additions
(#42814)
add 12afc1df98 Fix pytest from working outside breeze (#43082)
add e78421de87 Fix typo in ``pyproject.toml`` (#43077)
add 598e0ee8d7 Remove DAG.get_num_active_runs (#43067)
add 4effea2922 Fix UI lint pre-commit hook (#43086)
add 749526dd23 Fixed failing static checks (#43087)
add b7007e2b14 Added task_instance_mutation_hook for mapped operator index
0 (#42661)
add 4cdbc38ab1 Fix selective checks when only pyproject.toml changes
(#43088)
add fda45143cd fix(providers/mongo): prevent applying lower method on
boolean field (#43024)
add dfa6ad4b7e add kubernetes_conn_id to templated fields (#42786)
add f25ce51140 Add min version to cloudpickle (#43066)
add 51244221c3 Initialize dashboard page with health (#43090)
add 69e4a5e182 Update constraints to broken canary (#43095)
add 2b21e88a62 Fix flaky `test_get_dags` in FastAPI routes (#43100)
add b3b48501c7 SSHHook expose auth_timeout parameter (#43048)
add f587edf2ee vertex ai training operators: add display_name to rendered
fields (#43028)
add 3f8ac22caf Print the key name when max_length is exceeded (#43061)
add 7abc289be1 Revert "Fix flaky `test_get_dags` in FastAPI routes
(#43100)" (#43108)
add ec37818a04 Ensure stable secondary ordering (#43085)
add 9ce6d49eee Add simple "Task Execution" API server (#43015)
add 3ca80dd9a4 Add ClientConnectorError to be a retryable error in
databricks provider (#43091)
add c881565c07 passing the filetype for SlackAPIFileOperator (#43069)
add 2ed06d1e9f chore(docs): add required import of BranchDayOfWeekOperator
(#43053)
add b010acdf13 Update unit_tests.rst links error (#43114)
add 3b9e1569d3 added MultipleFilesWebHdfsSensor (#43045)
add 95e0c23bde Bump to `0.4.23` to fix a uv bug (#43121)
add 2576eea97b Clean up some eslint rules to better fit what we do (#43093)
add 571cf09e24 Fixed failing static checks & provider tests (#43122)
add 4a6d71fdf9 Add min version to python-ldap (#43104)
add 7324cdaa91 feat(providers/fab): Use asset in common provider (#43112)
add 61e3fa0ed3 Add `bugraoz93` in the triage team (#43124)
add c7b9c8dd32 Exclude backfill dag runs in active_runs_of_dags counts
(#42684)
add a2b32d6e7c feat(providers/amazon): Use asset in common provider
(#43110)
add ae96933761 Max active tasks to be evaluated per dag run (#42953)
add 8e6d396a30 Doc: Update example for dbt Cloud connection string (#43094)
add 824ec4a80d AIP-69: Add Executor to Edge Provider (#42048)
add ececdd3207 Speed-up rebuilding of CI image after pip/uv version change
(#43101)
add e286bd7192 Pin debian image version for Dataproc SparkR system test
(#43113)
add aeb7e90f0e Fix TestTranslationLegacyModelPredictLink dataset_id error
(#42463)
add 15f09c736a Add timezone selection to new UI (#43132)
add b86bb24984 37437 (#43107)
add 60b8056616 Fix broken stat scheduler_loop_duration (#42886)
add 8b15840b94 AIP-69: Breeze adjustments for introduction of Edge
Executor (#41731)
add 360a6c4220 Ignore "depends_on_past" for first run in a backfill
(#43131)
add 76c8470047 AIP-69: Add leftover glue of all pieces to Edge Provider
(#42051)
add b540eb0bfa Add docs about `cursor` extra param in Postgres Connection
(#43134)
add 1f0bba2e13 feat(providers/openlineage): Use asset in common provider
(#43111)
add 5eeea54fcb Bump ``uv`` to ``0.4.24`` (#43135)
add 66f9f3796e Add cross reference for Edge Executor in Airflow docs
(#43136)
add 2531338216 Airflow Core/Docs adjustments for introduction of AIP-69
Edge Executor (#41730)
add 424cf507a8 add min version to plyvel (#43129)
add 0de5587894 Add TimeoutError to be a retryable error in databricks
provider (#43137)
add 776764276f Provider package Edge: Edge worker supports queue handling
(#43115)
add 3f52c83058 Fix intermittent failure in UI Time test (#43147)
add fb49aa323b Always use logical date in DAG run header (#43148)
add b4269f33c7 Add `SageMakerProcessingSensor` (#43144)
add 68f8164a36 Fix provider title in documentation (#43157)
add 6ad428875e AIP-84 Get Variables (#43083)
add 2a791feb1d Remove hard-coded logger in tests (#43160)
add 7d6990fc7c Add `omkar-foss` to the triage team (#43169)
add a6c2f37de2 Remove `default` as auth backend (#43096)
add 4edcfc8799 pin min opentelemetry-exporter-prom version (#43143)
add 7635402e95 Making the security model more explicit (#43155)
add c497c5dea6 Fix side-effect of setting log handlers in tests (#43175)
add 6e9c53677a Remove ``from __future__`` from ``airflow/providers
__init__.py`` (#43173)
add 025082aeea Add more robust handling of existing DagRun (#43168)
add 72f2b2e951 Remove TaskContextLogger (#43183)
add 899dcbfcb2 pin min amqp (#43172)
add f0740b3105 Fix Selective checks for Task SDK (#43185)
add 57500b6608 (fix): HybridExecutor tasks of other executor rescheduled
in kubernetes executor (#43003)
add 0da9235ccb Docs: Typo Fix (#43199)
add 014808b362 Fix outdated CloudRunExecuteJobOperator docs (#43195)
add 930c0d7048 Bump ``pip`` to ``24.2`` (#43197)
add 04368b7500 Consider both commit authors and PR authors in status of
testing issue (#43192)
add f76d3b21f9 AIP-84 Delete Pool (#43165)
add e5f55377d2 Run Task SDK tests without DB (#43181)
add f37f29bc7e AIP-84 Get Providers (#43159)
add f3bd2c27bd AIP-84 | Public list tags API (#42959)
add 7ede73c85a Complete automation of version replacement pre-commit for
pip and uv (#43205)
add a7b1aa4833 Make sure all GitHub activity is archived (#43208)
add dc4def7c87 Rename Dataset database tables as Asset (#42023)
add 3b1188122f Remove accidental typo from CI docs (#43212)
add 8e9db955f6 [DatabricksHook] Respect connection settings (#42618)
add 892b2f18f1 Update cloudant versions to be py-version aware so `uv
lock` can work. (#43217)
add 84f329bfcd Start porting over all the DAG defintion code to the Task
SDK
add 8c19ed31ec Get more tests passing
add 075eed424d [skip ci]
add 96390cf636 [skip ci]
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 (e87f6c4e70)
\
N -- N -- N refs/heads/task-sdk-first-code (96390cf636)
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:
.asf.yaml | 6 +
.github/SECURITY.md | 9 +-
.github/workflows/ci.yml | 22 +-
.github/workflows/static-checks-mypy-docs.yml | 8 +-
.github/workflows/task-sdk-tests.yml | 18 +-
.pre-commit-config.yaml | 22 +-
Dockerfile | 18 +-
Dockerfile.ci | 40 +-
README.md | 2 +-
airflow/__init__.py | 5 +-
airflow/api/__init__.py | 8 +-
airflow/api/auth/backend/default.py | 42 -
airflow/api_connexion/endpoints/asset_endpoint.py | 10 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 2 +-
airflow/api_connexion/endpoints/pool_endpoint.py | 10 +-
.../api_connexion/endpoints/provider_endpoint.py | 2 +
.../api_connexion/endpoints/variable_endpoint.py | 1 +
airflow/api_connexion/openapi/v1.yaml | 76 +-
airflow/api_connexion/schemas/asset_schema.py | 4 +-
airflow/api_connexion/schemas/dag_schema.py | 2 +-
airflow/api_fastapi/app.py | 99 +-
airflow/api_fastapi/{db => common}/__init__.py | 0
.../api_fastapi/{openapi => common/db}/__init__.py | 0
airflow/api_fastapi/{ => common}/db/common.py | 2 +-
airflow/api_fastapi/{ => common}/db/dags.py | 0
airflow/api_fastapi/{ => common}/parameters.py | 43 +-
airflow/api_fastapi/{routes => common}/router.py | 0
.../api_fastapi/{routes => core_api}/__init__.py | 0
airflow/api_fastapi/{ => core_api}/app.py | 61 +-
.../{serializers => core_api/openapi}/__init__.py | 0
.../{ => core_api}/openapi/exceptions.py | 0
.../{ => core_api}/openapi/v1-generated.yaml | 285 +-
.../core_api/routes}/__init__.py | 0
.../{ => core_api}/routes/public/__init__.py | 16 +-
.../{ => core_api}/routes/public/connections.py | 13 +-
.../{ => core_api}/routes/public/dag_run.py | 8 +-
.../{ => core_api}/routes/public/dags.py | 51 +-
.../{ => core_api}/routes/public/monitor.py | 4 +-
.../api_fastapi/core_api/routes/public/pools.py | 48 +
.../core_api/routes/public/providers.py} | 41 +-
.../{ => core_api}/routes/public/variables.py | 49 +-
.../{ => core_api}/routes/ui/__init__.py | 6 +-
.../api_fastapi/{ => core_api}/routes/ui/assets.py | 12 +-
.../{ => core_api}/routes/ui/dashboard.py | 10 +-
.../core_api/serializers}/__init__.py | 0
.../{ => core_api}/serializers/connections.py | 0
.../{ => core_api}/serializers/dag_run.py | 0
.../api_fastapi/{ => core_api}/serializers/dags.py | 9 +-
.../{ => core_api}/serializers/dashboard.py | 2 +-
.../{ => core_api}/serializers/monitor.py | 0
.../api_fastapi/core_api/serializers/providers.py | 20 +-
.../{ => core_api}/serializers/variables.py | 7 +
.../execution_api}/__init__.py | 0
.../public/monitor.py => execution_api/app.py} | 20 +-
.../api_fastapi/execution_api/routes/__init__.py | 11 +-
.../api_fastapi/execution_api/routes/health.py | 11 +-
airflow/api_fastapi/main.py | 7 +-
airflow/assets/__init__.py | 15 +-
airflow/assets/manager.py | 8 +-
airflow/cli/cli_config.py | 6 +
airflow/cli/commands/fastapi_api_command.py | 12 +-
airflow/config_templates/config.yml | 17 +-
airflow/config_templates/unit_tests.cfg | 2 +-
airflow/configuration.py | 10 +-
airflow/dag_processing/collection.py | 50 +-
airflow/jobs/scheduler_job_runner.py | 140 +-
airflow/listeners/spec/asset.py | 4 +-
...8_3_0_0_tweak_assetaliasmodel_to_match_asset.py | 76 +
...3_0_0_add_exception_reason_and_logical_date_.py | 53 +
.../versions/0040_3_0_0_rename_dataset_as_asset.py | 693 ++++
airflow/models/abstractoperator.py | 9 +-
airflow/models/asset.py | 211 +-
airflow/models/backfill.py | 119 +-
airflow/models/baseoperator.py | 269 +-
airflow/models/dag.py | 66 +-
airflow/models/dagrun.py | 31 +-
airflow/models/mappedoperator.py | 4 +-
airflow/models/taskinstance.py | 26 +-
airflow/serialization/pydantic/asset.py | 8 +-
airflow/serialization/pydantic/dag_run.py | 2 +-
airflow/serialization/serialized_objects.py | 6 +-
airflow/ti_deps/deps/prev_dagrun_dep.py | 16 +-
airflow/timetables/assets.py | 2 +-
airflow/ui/openapi-gen/queries/common.ts | 71 +
airflow/ui/openapi-gen/queries/prefetch.ts | 89 +
airflow/ui/openapi-gen/queries/queries.ts | 151 +
airflow/ui/openapi-gen/queries/suspense.ts | 113 +
airflow/ui/openapi-gen/requests/schemas.gen.ts | 95 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 124 +
airflow/ui/openapi-gen/requests/types.gen.ts | 159 +-
airflow/ui/package.json | 3 +-
airflow/ui/pnpm-lock.yaml | 8 +
airflow/ui/rules/perfectionist.js | 42 +-
airflow/ui/rules/typescript.js | 19 +-
airflow/ui/rules/unicorn.js | 38 +-
airflow/ui/src/App.tsx | 5 +-
airflow/ui/src/components/Time.test.tsx | 65 +
airflow/ui/src/components/Time.tsx | 61 +
.../ui/src/context/timezone/TimezoneProvider.tsx | 59 +
.../ui/src/{App.tsx => context/timezone/index.ts} | 15 +-
.../{App.tsx => context/timezone/useTimezone.ts} | 21 +-
airflow/ui/src/layouts/Nav/Nav.tsx | 17 +-
.../src/{App.tsx => layouts/Nav/TimezoneModal.tsx} | 37 +-
airflow/ui/src/layouts/Nav/TimezoneSelector.tsx | 89 +
airflow/ui/src/layouts/Nav/UserSettingsButton.tsx | 19 +-
airflow/ui/src/main.tsx | 5 +-
airflow/ui/src/pages/DagsList/DagCard.tsx | 5 +-
airflow/ui/src/pages/DagsList/DagsList.tsx | 7 +-
.../src/{App.tsx => pages/Dashboard/Dashboard.tsx} | 19 +-
airflow/ui/src/pages/Dashboard/Health.tsx | 67 +
airflow/ui/src/pages/Dashboard/HealthSection.tsx | 59 +
airflow/ui/src/pages/Dashboard/HealthTag.tsx | 62 +
.../ui/src/{App.tsx => pages/Dashboard/index.tsx} | 14 +-
airflow/ui/src/theme.ts | 2 -
airflow/ui/src/utils/Wrapper.tsx | 6 +-
airflow/ui/src/{App.tsx => utils/capitalize.ts} | 16 +-
airflow/ui/src/{App.tsx => utils/index.ts} | 15 +-
airflow/ui/tsconfig.app.json | 4 +-
airflow/utils/context.py | 2 +-
airflow/utils/db.py | 2 +-
airflow/utils/db_cleanup.py | 2 +-
airflow/utils/helpers.py | 2 +-
airflow/utils/log/file_task_handler.py | 5 -
airflow/utils/log/task_context_logger.py | 188 -
airflow/utils/types.py | 4 +-
airflow/www/extensions/init_security.py | 8 +-
airflow/www/jest-setup.js | 2 +-
.../www/static/js/cluster-activity/index.test.tsx | 2 +-
.../www/static/js/components/DatasetEventCard.tsx | 10 +-
airflow/www/static/js/components/RunTypeIcon.tsx | 2 +-
airflow/www/static/js/dag/details/Header.tsx | 2 +-
airflow/www/static/js/dag/details/dag/Dag.tsx | 4 +-
.../js/dag/details/dagRun/DatasetTriggerEvents.tsx | 2 +-
airflow/www/static/js/dag/details/dagRun/index.tsx | 4 +-
airflow/www/static/js/dag/details/graph/index.tsx | 30 +-
airflow/www/static/js/dag/details/graph/utils.ts | 2 +-
.../details/taskInstance/DatasetUpdateEvents.tsx | 2 +-
airflow/www/static/js/datasetUtils.js | 6 +-
airflow/www/static/js/datasets/AssetEvents.tsx | 2 +-
airflow/www/static/js/types/api-generated.ts | 165 +-
airflow/www/static/js/types/index.ts | 2 +-
airflow/www/static/js/utils/index.test.ts | 8 +-
airflow/www/static/js/utils/index.ts | 2 +-
...xt_run_modal.html => asset_next_run_modal.html} | 2 +-
.../airflow/{datasets.html => assets.html} | 0
airflow/www/templates/airflow/dag.html | 29 +-
airflow/www/templates/airflow/dags.html | 8 +-
airflow/www/views.py | 62 +-
contributing-docs/08_static_code_checks.rst | 3 +
contributing-docs/17_adding_api_endpoints.rst | 6 +-
contributing-docs/testing/unit_tests.rst | 2 +-
dev/breeze/doc/05_test_commands.rst | 21 +
dev/breeze/doc/ci/02_images.md | 61 +-
dev/breeze/doc/ci/04_selective_checks.md | 2 +-
.../doc/images/output_k8s_deploy-airflow.svg | 2 +-
.../doc/images/output_k8s_deploy-airflow.txt | 2 +-
.../doc/images/output_k8s_run-complete-tests.svg | 2 +-
.../doc/images/output_k8s_run-complete-tests.txt | 2 +-
dev/breeze/doc/images/output_k8s_shell.svg | 2 +-
dev/breeze/doc/images/output_k8s_shell.txt | 2 +-
dev/breeze/doc/images/output_k8s_tests.svg | 2 +-
dev/breeze/doc/images/output_k8s_tests.txt | 2 +-
.../output_setup_check-all-params-in-groups.svg | 2 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 2 +-
.../output_setup_regenerate-command-images.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 234 +-
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 2 +-
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
dev/breeze/doc/images/output_static-checks.svg | 4 +-
dev/breeze/doc/images/output_static-checks.txt | 2 +-
dev/breeze/doc/images/output_testing.svg | 26 +-
dev/breeze/doc/images/output_testing.txt | 2 +-
dev/breeze/doc/images/output_testing_db-tests.svg | 6 +-
dev/breeze/doc/images/output_testing_db-tests.txt | 2 +-
.../doc/images/output_testing_non-db-tests.svg | 6 +-
.../doc/images/output_testing_non-db-tests.txt | 2 +-
.../doc/images/output_testing_task-sdk-tests.svg | 296 ++
.../doc/images/output_testing_task-sdk-tests.txt | 1 +
dev/breeze/doc/images/output_testing_tests.svg | 8 +-
dev/breeze/doc/images/output_testing_tests.txt | 2 +-
.../commands/release_management_commands.py | 20 +-
.../airflow_breeze/commands/testing_commands.py | 62 +
.../commands/testing_commands_config.py | 48 +
dev/breeze/src/airflow_breeze/global_constants.py | 29 +-
.../src/airflow_breeze/params/shell_params.py | 7 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 1 +
dev/breeze/src/airflow_breeze/utils/run_tests.py | 11 +-
.../src/airflow_breeze/utils/selective_checks.py | 51 +-
dev/breeze/tests/test_packages.py | 12 +-
dev/breeze/tests/test_selective_checks.py | 258 +-
.../operators/sagemaker.rst | 14 +
.../index.rst | 4 +-
.../connections.rst | 9 +-
.../apache-airflow-providers-edge/cli-ref.rst | 33 +-
.../edge_executor.rst | 262 ++
docs/apache-airflow-providers-edge/index.rst | 9 +
.../connections/postgres.rst | 7 +
docs/apache-airflow/cli-and-env-variables-ref.rst | 1 +
.../core-concepts/executor/index.rst | 2 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 4089 ++++++++++----------
docs/apache-airflow/migrations-ref.rst | 8 +-
generated/provider_dependencies.json | 6 +-
hatch_build.py | 11 +-
newsfragments/42023.significant.rst | 9 +
newsfragments/42953.significant | 3 +
newsfragments/43067.significant.rst | 4 +
newsfragments/43096.significant.rst | 1 +
newsfragments/43183.significant.rst | 5 +
providers/src/airflow/providers/__init__.py | 4 +-
.../src/airflow/providers/amazon/CHANGELOG.rst | 2 +-
.../src/airflow/providers/amazon/aws/assets/s3.py | 14 +-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 106 +-
.../providers/amazon/aws/hooks/sagemaker.py | 2 +
.../providers/amazon/aws/sensors/sagemaker.py | 32 +
.../aws/utils/asset_compat_lineage_collector.py | 106 -
.../src/airflow/providers/amazon/provider.yaml | 2 +-
.../providers/apache/hdfs/sensors/web_hdfs.py | 37 +
.../src/airflow/providers/cloudant/provider.yaml | 4 +-
.../kubernetes/executors/kubernetes_executor.py | 22 +-
.../providers/cncf/kubernetes/operators/pod.py | 1 +
.../cncf/kubernetes/operators/spark_kubernetes.py | 2 +-
.../airflow/providers/common/sql/sensors/sql.py | 23 +-
.../providers/databricks/hooks/databricks_base.py | 14 +-
providers/src/airflow/providers/edge/CHANGELOG.rst | 8 +
.../src/airflow/providers/edge/cli/edge_command.py | 24 +-
.../airflow/providers/edge/executors/__init__.py | 4 +-
.../providers/edge/executors/edge_executor.py | 186 +
.../airflow/providers/edge/models/edge_worker.py | 55 +-
providers/src/airflow/providers/edge/provider.yaml | 5 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 5 +-
.../fab/auth_manager/security_manager/override.py | 5 +-
providers/src/airflow/providers/fab/provider.yaml | 2 +-
.../providers/google/cloud/links/translate.py | 3 +-
.../providers/google/cloud/operators/automl.py | 49 +-
.../providers/google/cloud/operators/cloud_run.py | 10 +-
.../google/cloud/operators/vertex_ai/auto_ml.py | 11 +-
.../operators/vertex_ai/batch_prediction_job.py | 2 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 19 +
.../vertex_ai/hyperparameter_tuning_job.py | 1 +
.../src/airflow/providers/google/provider.yaml | 2 +-
.../src/airflow/providers/mongo/hooks/mongo.py | 6 +-
.../providers/openlineage/extractors/manager.py | 37 +-
.../utils/asset_compat_lineage_collector.py | 108 -
.../airflow/providers/openlineage/utils/utils.py | 47 +-
.../src/airflow/providers/slack/operators/slack.py | 1 +
providers/src/airflow/providers/ssh/hooks/ssh.py | 4 +
.../providers/standard/operators/weekday.py | 2 +
.../alibaba/cloud/log/test_oss_task_handler.py | 5 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 3 +-
.../aws/auth_manager/cli/test_avp_commands.py | 5 +-
.../test_aws_security_manager_override.py | 1 +
.../aws/auth_manager/test_aws_auth_manager.py | 15 +-
.../amazon/aws/auth_manager/views/test_auth.py | 5 +-
.../aws/executors/batch/test_batch_executor.py | 5 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 7 +-
providers/tests/amazon/aws/hooks/test_base_aws.py | 3 +-
providers/tests/amazon/aws/hooks/test_s3.py | 5 +-
providers/tests/amazon/aws/links/test_base_aws.py | 5 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 3 +-
.../tests/amazon/aws/log/test_s3_task_handler.py | 3 +-
.../amazon/aws/secrets/test_systems_manager.py | 3 +-
.../aws/sensors/test_sagemaker_processing.py | 110 +
.../amazon/aws/transfers/test_redshift_to_s3.py | 3 +-
.../amazon/aws/transfers/test_s3_to_redshift.py | 3 +-
.../tests/amazon/aws/transfers/test_s3_to_sftp.py | 3 +-
.../tests/amazon/aws/transfers/test_sftp_to_s3.py | 3 +-
.../tests/apache/hdfs/sensors/test_web_hdfs.py | 49 +-
providers/tests/apache/hive/hooks/test_hive.py | 2 +-
providers/tests/apache/livy/hooks/test_livy.py | 3 +-
.../tests/apache/spark/hooks/test_spark_sql.py | 3 +-
providers/tests/atlassian/jira/hooks/test_jira.py | 3 +-
.../tests/atlassian/jira/operators/test_jira.py | 3 +-
.../tests/atlassian/jira/sensors/test_jira.py | 3 +-
providers/tests/celery/cli/test_celery_command.py | 5 +-
.../tests/celery/executors/test_celery_executor.py | 7 +-
.../tests/celery/log_handlers/test_log_handlers.py | 5 +-
.../cncf/kubernetes/cli/test_kubernetes_command.py | 3 +-
.../executors/test_kubernetes_executor.py | 218 +-
.../tests/cncf/kubernetes/hooks/test_kubernetes.py | 5 +-
.../kubernetes/log_handlers/test_log_handlers.py | 5 +-
.../tests/cncf/kubernetes/operators/test_pod.py | 3 +-
.../kubernetes/operators/test_spark_kubernetes.py | 3 +-
providers/tests/cncf/kubernetes/test_client.py | 3 +-
.../cncf/kubernetes/test_template_rendering.py | 3 +-
.../common/io/operators/test_file_transfer.py | 4 +-
providers/tests/common/io/xcom/test_backend.py | 7 +-
providers/tests/common/sql/hooks/test_dbapi.py | 3 +-
providers/tests/common/sql/hooks/test_sql.py | 2 +-
providers/tests/common/sql/hooks/test_sqlparse.py | 3 +-
providers/tests/common/sql/operators/test_sql.py | 3 +-
.../tests/common/sql/operators/test_sql_execute.py | 3 +-
providers/tests/common/sql/sensors/test_sql.py | 28 +-
providers/tests/common/sql/test_utils.py | 3 +-
.../tests/databricks/hooks/test_databricks.py | 108 +
.../databricks/plugins/test_databricks_workflow.py | 3 +-
.../edge/api_endpoints/test_rpc_api_endpoint.py | 5 +-
providers/tests/edge/cli/test_edge_command.py | 24 +-
.../tests/edge/executors}/__init__.py | 0
.../tests/edge/executors/test_edge_executor.py | 152 +
providers/tests/edge/models/test_edge_worker.py | 70 +-
.../edge/plugins/test_edge_executor_plugin.py | 3 +-
.../elasticsearch/log/test_es_task_handler.py | 4 +-
.../api/auth/backend/test_basic_auth.py | 3 +-
.../auth_manager/api/auth/backend/test_session.py | 3 +-
.../api_endpoints/test_asset_endpoint.py | 62 +-
.../fab/auth_manager/api_endpoints/test_auth.py | 1 +
.../api_endpoints/test_backfill_endpoint.py | 14 +-
.../fab/auth_manager/api_endpoints/test_cors.py | 1 +
.../api_endpoints/test_dag_endpoint.py | 10 +-
.../api_endpoints/test_dag_run_endpoint.py | 4 +-
.../api_endpoints/test_dag_source_endpoint.py | 4 +-
.../api_endpoints/test_dag_warning_endpoint.py | 4 +-
.../api_endpoints/test_event_log_endpoint.py | 4 +-
.../api_endpoints/test_import_error_endpoint.py | 6 +-
.../test_role_and_permission_endpoint.py | 4 +-
.../api_endpoints/test_task_instance_endpoint.py | 4 +-
.../api_endpoints/test_user_endpoint.py | 6 +-
.../api_endpoints/test_variable_endpoint.py | 4 +-
.../api_endpoints/test_xcom_endpoint.py | 4 +-
.../auth_manager/cli_commands/test_role_command.py | 5 +-
.../cli_commands/test_sync_perm_command.py | 3 +-
.../auth_manager/cli_commands/test_user_command.py | 3 +-
.../fab/auth_manager/cli_commands/test_utils.py | 1 +
providers/tests/fab/auth_manager/conftest.py | 5 +-
.../tests/fab/auth_manager/decorators/test_auth.py | 3 +-
.../fab/auth_manager/schemas/test_user_schema.py | 2 +-
.../fab/auth_manager/test_fab_auth_manager.py | 9 +-
providers/tests/fab/auth_manager/test_models.py | 1 +
providers/tests/fab/auth_manager/test_security.py | 17 +-
.../fab/auth_manager/views/test_permissions.py | 4 +-
.../fab/auth_manager/views/test_roles_list.py | 4 +-
.../tests/fab/auth_manager/views/test_user.py | 4 +-
.../tests/fab/auth_manager/views/test_user_edit.py | 4 +-
.../fab/auth_manager/views/test_user_stats.py | 4 +-
.../google/cloud/hooks/test_bigquery_system.py | 2 +-
.../tests/google/cloud/hooks/test_kms_system.py | 2 +-
.../cloud/hooks/test_secret_manager_system.py | 2 +-
.../tests/google/cloud/links/test_translate.py | 8 +-
.../google/cloud/log/test_gcs_task_handler.py | 5 +-
.../cloud/log/test_gcs_task_handler_system.py | 14 +-
.../cloud/log/test_stackdriver_task_handler.py | 7 +-
.../log/test_stackdriver_task_handler_system.py | 14 +-
.../tests/google/cloud/operators/test_automl.py | 4 +
.../tests/google/cloud/operators/test_bigquery.py | 13 +-
.../google/cloud/operators/test_bigquery_dts.py | 3 +-
.../google/cloud/operators/test_dataprep_system.py | 7 +-
.../tests/google/cloud/operators/test_dataproc.py | 5 +-
.../cloud/operators/test_datastore_system.py | 4 +-
.../tests/google/cloud/operators/test_looker.py | 3 +-
.../cloud/secrets/test_secret_manager_system.py | 2 +-
.../transfers/test_facebook_ads_to_gcs_system.py | 10 +-
.../transfers/test_salesforce_to_gcs_system.py | 8 +-
.../tests/google/cloud/utils/gcp_authenticator.py | 6 +-
.../common/auth_backend/test_google_openid.py | 5 +-
.../operators/test_display_video_system.py | 12 +-
providers/tests/hashicorp/hooks/test_vault.py | 3 +-
providers/tests/imap/hooks/test_imap.py | 3 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 5 +-
providers/tests/mongo/hooks/test_mongo.py | 15 +-
providers/tests/mysql/hooks/test_mysql.py | 4 +-
.../tests/openlineage/extractors/test_bash.py | 3 +-
.../tests/openlineage/extractors/test_manager.py | 71 +-
.../tests/openlineage/extractors/test_python.py | 3 +-
.../tests/openlineage/plugins/test_adapter.py | 5 +-
.../tests/openlineage/plugins/test_execution.py | 5 +-
.../tests/openlineage/plugins/test_listener.py | 5 +-
.../tests/openlineage/plugins/test_openlineage.py | 1 +
providers/tests/openlineage/plugins/test_utils.py | 3 +-
providers/tests/openlineage/test_conf.py | 3 +-
providers/tests/openlineage/utils/test_utils.py | 6 +-
.../tests/opensearch/log/test_os_task_handler.py | 4 +-
.../tests/redis/log/test_redis_task_handler.py | 3 +-
providers/tests/sftp/operators/test_sftp.py | 3 +-
providers/tests/slack/operators/test_slack.py | 2 +
providers/tests/smtp/hooks/test_smtp.py | 3 +-
providers/tests/smtp/notifications/test_smtp.py | 5 +-
providers/tests/ssh/hooks/test_ssh.py | 12 +
providers/tests/ssh/operators/test_ssh.py | 3 +-
providers/tests/standard/operators/test_bash.py | 3 +-
.../tests/standard/operators/test_datetime.py | 3 +-
providers/tests/standard/operators/test_weekday.py | 3 +-
providers/tests/standard/sensors/test_weekday.py | 3 +-
.../tests/system/amazon/aws/example_s3_to_sql.py | 3 +-
.../tests/system/amazon/aws/example_sagemaker.py | 13 +
.../amazon/aws/tests/test_aws_auth_manager.py | 4 +-
.../tests/system/dbt/cloud/example_dbt_cloud.py | 4 +-
.../cloud/dataproc/example_dataproc_sparkr.py | 3 +
.../tests/system/yandex/example_yandexcloud.py | 3 +-
.../system/yandex/example_yandexcloud_dataproc.py | 4 +-
.../example_yandexcloud_dataproc_lightweight.py | 4 +-
.../tests/system/yandex/example_yandexcloud_yq.py | 4 +-
providers/tests/yandex/hooks/test_yandex.py | 4 +-
providers/tests/yandex/links/test_yq.py | 5 +-
providers/tests/yandex/operators/test_yq.py | 1 +
pyproject.toml | 8 +-
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/pre_commit/mypy_folder.py | 15 +-
scripts/ci/pre_commit/update_installers.py | 86 +-
scripts/docker/common.sh | 16 +-
scripts/in_container/bin/run_tmux | 17 +
.../in_container/install_airflow_and_providers.py | 2 -
.../in_container/run_update_fastapi_api_spec.py | 2 +-
task_sdk/README.md | 4 +
task_sdk/pyproject.toml | 2 +-
.../airflow/sdk/definitions/abstractoperator.py | 6 +-
.../src/airflow/sdk/definitions/baseoperator.py | 1 +
task_sdk/src/airflow/sdk/definitions/dag.py | 6 +-
task_sdk/tests/conftest.py | 5 +
tests/always/test_connection.py | 1 +
tests/always/test_example_dags.py | 1 +
tests/always/test_secrets.py | 1 +
tests/always/test_secrets_backends.py | 1 +
tests/always/test_secrets_local_filesystem.py | 1 +
tests/api_connexion/conftest.py | 1 +
.../api_connexion/endpoints/test_asset_endpoint.py | 47 +-
.../endpoints/test_backfill_endpoint.py | 1 +
.../endpoints/test_connection_endpoint.py | 1 +
tests/api_connexion/endpoints/test_dag_endpoint.py | 21 +-
tests/api_connexion/endpoints/test_dag_parsing.py | 3 +-
.../endpoints/test_dag_run_endpoint.py | 11 +-
.../endpoints/test_dag_source_endpoint.py | 1 +
.../endpoints/test_dag_stats_endpoint.py | 1 +
.../endpoints/test_dag_warning_endpoint.py | 1 +
.../endpoints/test_event_log_endpoint.py | 1 +
.../endpoints/test_extra_link_endpoint.py | 1 +
.../endpoints/test_import_error_endpoint.py | 1 +
tests/api_connexion/endpoints/test_log_endpoint.py | 1 +
.../test_mapped_task_instance_endpoint.py | 1 +
.../endpoints/test_plugin_endpoint.py | 1 +
.../api_connexion/endpoints/test_pool_endpoint.py | 1 +
.../endpoints/test_provider_endpoint.py | 1 +
.../api_connexion/endpoints/test_task_endpoint.py | 1 +
.../endpoints/test_task_instance_endpoint.py | 1 +
.../endpoints/test_variable_endpoint.py | 1 +
.../api_connexion/endpoints/test_xcom_endpoint.py | 1 +
.../schemas/test_connection_schema.py | 1 +
tests/api_connexion/schemas/test_dag_run_schema.py | 1 +
tests/api_connexion/schemas/test_dataset_schema.py | 31 +-
tests/api_connexion/schemas/test_error_schema.py | 1 +
tests/api_connexion/schemas/test_plugin_schema.py | 1 +
tests/api_connexion/schemas/test_pool_schemas.py | 1 +
tests/api_connexion/schemas/test_xcom_schema.py | 1 +
tests/api_connexion/test_auth.py | 1 +
tests/api_connexion/test_parameters.py | 1 +
tests/api_fastapi/conftest.py | 11 +
.../api_fastapi/core_api}/__init__.py | 0
.../api_fastapi/core_api/routes}/__init__.py | 0
.../core_api/routes/public}/__init__.py | 0
.../routes/public/test_connections.py | 1 +
.../{ => core_api}/routes/public/test_dag_run.py | 3 +-
.../{ => core_api}/routes/public/test_dags.py | 129 +-
.../{ => core_api}/routes/public/test_monitor.py | 1 +
.../core_api/routes/public/test_pools.py | 78 +
.../core_api/routes/public/test_providers.py | 75 +
.../{ => core_api}/routes/public/test_variables.py | 43 +-
.../api_fastapi/core_api/routes/ui}/__init__.py | 0
.../{ => core_api}/routes/ui/test_assets.py | 3 +-
.../{ => core_api}/routes/ui/test_dashboard.py | 7 +-
.../api_fastapi/execution_api}/__init__.py | 0
.../api_fastapi/execution_api/routes}/__init__.py | 0
.../execution_api/routes/test_health.py | 8 +-
tests/api_fastapi/routes/__init__.py | 16 -
tests/api_fastapi/routes/public/__init__.py | 16 -
tests/api_fastapi/routes/ui/__init__.py | 16 -
tests/api_fastapi/test_app.py | 71 +
.../endpoints/test_rpc_api_endpoint.py | 1 +
tests/api_internal/test_internal_api_call.py | 1 +
tests/assets/test_asset.py | 6 +-
tests/assets/test_manager.py | 6 +-
tests/auth/managers/simple/views/test_auth.py | 1 +
tests/cli/commands/test_backfill_command.py | 1 +
tests/cli/commands/test_celery_command.py | 1 +
tests/cli/commands/test_config_command.py | 1 +
tests/cli/commands/test_connection_command.py | 1 +
tests/cli/commands/test_dag_command.py | 4 +-
tests/cli/commands/test_dag_processor_command.py | 1 +
tests/cli/commands/test_fastapi_api_command.py | 47 +-
tests/cli/commands/test_info_command.py | 1 +
tests/cli/commands/test_internal_api_command.py | 2 +-
tests/cli/commands/test_jobs_command.py | 1 +
tests/cli/commands/test_kerberos_command.py | 1 +
tests/cli/commands/test_kubernetes_command.py | 1 +
tests/cli/commands/test_plugins_command.py | 2 +-
.../cli/commands/test_rotate_fernet_key_command.py | 1 +
tests/cli/commands/test_scheduler_command.py | 1 +
tests/cli/commands/test_task_command.py | 3 +-
tests/cli/commands/test_variable_command.py | 1 +
tests/cli/commands/test_webserver_command.py | 2 +-
tests/cli/conftest.py | 1 +
tests/cli/test_cli_parser.py | 1 +
tests/conftest.py | 23 +
tests/core/test_configuration.py | 6 +-
tests/core/test_core.py | 1 +
tests/core/test_example_dags_system.py | 1 +
tests/core/test_impersonation_tests.py | 1 +
tests/core/test_logging_config.py | 1 +
tests/core/test_otel_tracer.py | 1 +
tests/core/test_sentry.py | 1 +
tests/core/test_settings.py | 1 +
tests/core/test_sqlalchemy_config.py | 1 +
tests/core/test_stats.py | 1 +
tests/dag_processing/test_job_runner.py | 6 +-
tests/dag_processing/test_processor.py | 1 +
tests/dags/test_assets.py | 12 +-
tests/dags/test_miscellaneous.py | 1 +
tests/dags/test_sensor.py | 1 +
tests/decorators/test_bash.py | 1 +
tests/decorators/test_python.py | 2 +-
tests/executors/test_executor_loader.py | 1 +
.../cli/commands/test_celery_command.py | 1 +
.../integration/executors/test_celery_executor.py | 1 +
tests/integration/security/test_kerberos.py | 1 +
tests/jobs/test_base_job.py | 2 +-
tests/jobs/test_local_task_job.py | 1 +
tests/jobs/test_scheduler_job.py | 359 +-
tests/jobs/test_triggerer_job.py | 6 +-
tests/jobs/test_triggerer_job_logging.py | 21 +-
tests/lineage/test_hook.py | 1 +
tests/lineage/test_lineage.py | 1 +
tests/listeners/class_listener.py | 1 +
tests/listeners/test_dag_import_error_listener.py | 4 +-
tests/models/test_backfill.py | 143 +-
tests/models/test_base.py | 1 +
tests/models/test_baseoperator.py | 1 +
tests/models/test_cleartasks.py | 4 +-
tests/models/test_dag.py | 60 +-
tests/models/test_dagbag.py | 6 +-
tests/models/test_dagcode.py | 1 +
tests/models/test_dagrun.py | 10 +-
tests/models/test_dagwarning.py | 1 +
tests/models/test_mappedoperator.py | 29 +-
tests/models/test_param.py | 1 +
tests/models/test_pool.py | 1 +
tests/models/test_renderedtifields.py | 1 +
tests/models/test_serialized_dag.py | 1 +
tests/models/test_skipmixin.py | 1 +
tests/models/test_taskinstance.py | 66 +-
tests/models/test_timestamp.py | 1 +
tests/models/test_trigger.py | 1 +
tests/models/test_variable.py | 1 +
tests/models/test_xcom.py | 1 +
tests/models/test_xcom_arg.py | 1 +
tests/operators/test_branch_operator.py | 1 +
tests/operators/test_email.py | 1 +
tests/operators/test_latest_only_operator.py | 1 +
tests/operators/test_python.py | 1 +
tests/plugins/test_plugin.py | 6 +-
tests/plugins/test_plugins_manager.py | 1 +
tests/secrets/test_cache.py | 1 +
tests/security/test_kerberos.py | 1 +
tests/sensors/test_base.py | 1 +
tests/sensors/test_external_task_sensor.py | 4 +-
tests/serialization/test_dag_serialization.py | 1 +
tests/serialization/test_pydantic_models.py | 42 +-
tests/serialization/test_serde.py | 15 +-
tests/serialization/test_serialized_objects.py | 1 +
.../task/task_runner/test_standard_task_runner.py | 4 +-
.../ti_deps/deps/test_pool_slots_available_dep.py | 1 +
tests/ti_deps/deps/test_prev_dagrun_dep.py | 194 +-
tests/ti_deps/deps/test_ready_to_reschedule_dep.py | 1 +
tests/timetables/test_assets_timetable.py | 6 +-
tests/utils/log/test_log_reader.py | 1 +
tests/utils/log/test_secrets_masker.py | 1 +
tests/utils/log/test_task_context_logger.py | 138 -
tests/utils/test_db.py | 1 +
tests/utils/test_db_cleanup.py | 15 +-
tests/utils/test_db_manager.py | 1 +
tests/utils/test_dot_renderer.py | 1 +
tests/utils/test_email.py | 1 +
tests/utils/test_file.py | 2 +-
tests/utils/test_helpers.py | 3 +-
tests/utils/test_log_handlers.py | 1 +
tests/utils/test_net.py | 1 +
tests/utils/test_serve_logs.py | 1 +
tests/utils/test_sqlalchemy.py | 1 +
tests/utils/test_state.py | 2 +-
tests/utils/test_task_group.py | 2 +-
.../test_task_handler_with_custom_formatter.py | 1 +
tests/utils/test_types.py | 2 +-
tests/www/test_app.py | 1 +
tests/www/test_utils.py | 1 +
tests/www/test_validators.py | 2 +-
tests/www/views/conftest.py | 1 +
tests/www/views/test_anonymous_as_admin_role.py | 1 +
tests/www/views/test_session.py | 1 +
tests/www/views/test_views.py | 3 +
tests/www/views/test_views_acl.py | 4 +-
tests/www/views/test_views_base.py | 1 +
tests/www/views/test_views_cluster_activity.py | 7 +-
tests/www/views/test_views_configuration.py | 1 +
tests/www/views/test_views_connection.py | 1 +
tests/www/views/test_views_custom_user_views.py | 10 +-
tests/www/views/test_views_dagrun.py | 12 +-
tests/www/views/test_views_dataset.py | 105 +-
tests/www/views/test_views_decorators.py | 1 +
tests/www/views/test_views_extra_links.py | 1 +
tests/www/views/test_views_grid.py | 35 +-
tests/www/views/test_views_home.py | 4 +-
tests/www/views/test_views_log.py | 1 +
tests/www/views/test_views_mount.py | 1 +
tests/www/views/test_views_paused.py | 1 +
tests/www/views/test_views_pool.py | 1 +
tests/www/views/test_views_rate_limit.py | 1 +
tests/www/views/test_views_rendered.py | 1 +
tests/www/views/test_views_tasks.py | 12 +-
tests/www/views/test_views_trigger_dag.py | 6 +-
tests/www/views/test_views_variable.py | 4 +-
tests_common/pytest_plugin.py | 35 +-
tests_common/test_utils/api_connexion_utils.py | 1 +
tests_common/test_utils/azure_system_helpers.py | 1 +
tests_common/test_utils/db.py | 2 +
tests_common/test_utils/gcp_system_helpers.py | 4 +-
.../test_utils/log_handlers.py | 5 +-
tests_common/test_utils/mock_executor.py | 4 +-
tests_common/test_utils/mock_operators.py | 1 +
tests_common/test_utils/system_tests_class.py | 1 +
619 files changed, 10434 insertions(+), 5293 deletions(-)
delete mode 100644 airflow/api/auth/backend/default.py
rename airflow/api_fastapi/{db => common}/__init__.py (100%)
rename airflow/api_fastapi/{openapi => common/db}/__init__.py (100%)
rename airflow/api_fastapi/{ => common}/db/common.py (97%)
rename airflow/api_fastapi/{ => common}/db/dags.py (100%)
rename airflow/api_fastapi/{ => common}/parameters.py (88%)
rename airflow/api_fastapi/{routes => common}/router.py (100%)
rename airflow/api_fastapi/{routes => core_api}/__init__.py (100%)
copy airflow/api_fastapi/{ => core_api}/app.py (64%)
rename airflow/api_fastapi/{serializers => core_api/openapi}/__init__.py (100%)
rename airflow/api_fastapi/{ => core_api}/openapi/exceptions.py (100%)
rename airflow/api_fastapi/{ => core_api}/openapi/v1-generated.yaml (87%)
copy airflow/{api_connexion => api_fastapi/core_api/routes}/__init__.py (100%)
rename airflow/api_fastapi/{ => core_api}/routes/public/__init__.py (61%)
rename airflow/api_fastapi/{ => core_api}/routes/public/connections.py (87%)
rename airflow/api_fastapi/{ => core_api}/routes/public/dag_run.py (88%)
rename airflow/api_fastapi/{ => core_api}/routes/public/dags.py (83%)
copy airflow/api_fastapi/{ => core_api}/routes/public/monitor.py (89%)
create mode 100644 airflow/api_fastapi/core_api/routes/public/pools.py
copy airflow/{api_connexion/endpoints/provider_endpoint.py =>
api_fastapi/core_api/routes/public/providers.py} (54%)
rename airflow/api_fastapi/{ => core_api}/routes/public/variables.py (72%)
rename airflow/api_fastapi/{ => core_api}/routes/ui/__init__.py (81%)
rename airflow/api_fastapi/{ => core_api}/routes/ui/assets.py (88%)
rename airflow/api_fastapi/{ => core_api}/routes/ui/dashboard.py (90%)
copy airflow/{api_connexion => api_fastapi/core_api/serializers}/__init__.py
(100%)
rename airflow/api_fastapi/{ => core_api}/serializers/connections.py (100%)
rename airflow/api_fastapi/{ => core_api}/serializers/dag_run.py (100%)
rename airflow/api_fastapi/{ => core_api}/serializers/dags.py (96%)
rename airflow/api_fastapi/{ => core_api}/serializers/dashboard.py (98%)
rename airflow/api_fastapi/{ => core_api}/serializers/monitor.py (100%)
copy tests/api_fastapi/conftest.py =>
airflow/api_fastapi/core_api/serializers/providers.py (70%)
rename airflow/api_fastapi/{ => core_api}/serializers/variables.py (91%)
copy airflow/{api_connexion => api_fastapi/execution_api}/__init__.py (100%)
rename airflow/api_fastapi/{routes/public/monitor.py => execution_api/app.py}
(62%)
copy task_sdk/tests/conftest.py =>
airflow/api_fastapi/execution_api/routes/__init__.py (78%)
copy task_sdk/tests/conftest.py =>
airflow/api_fastapi/execution_api/routes/health.py (80%)
create mode 100644
airflow/migrations/versions/0038_3_0_0_tweak_assetaliasmodel_to_match_asset.py
create mode 100644
airflow/migrations/versions/0039_3_0_0_add_exception_reason_and_logical_date_.py
create mode 100644
airflow/migrations/versions/0040_3_0_0_rename_dataset_as_asset.py
create mode 100644 airflow/ui/src/components/Time.test.tsx
create mode 100644 airflow/ui/src/components/Time.tsx
create mode 100644 airflow/ui/src/context/timezone/TimezoneProvider.tsx
copy airflow/ui/src/{App.tsx => context/timezone/index.ts} (68%)
copy airflow/ui/src/{App.tsx => context/timezone/useTimezone.ts} (68%)
copy airflow/ui/src/{App.tsx => layouts/Nav/TimezoneModal.tsx} (55%)
create mode 100644 airflow/ui/src/layouts/Nav/TimezoneSelector.tsx
copy airflow/ui/src/{App.tsx => pages/Dashboard/Dashboard.tsx} (68%)
create mode 100644 airflow/ui/src/pages/Dashboard/Health.tsx
create mode 100644 airflow/ui/src/pages/Dashboard/HealthSection.tsx
create mode 100644 airflow/ui/src/pages/Dashboard/HealthTag.tsx
copy airflow/ui/src/{App.tsx => pages/Dashboard/index.tsx} (68%)
copy airflow/ui/src/{App.tsx => utils/capitalize.ts} (68%)
copy airflow/ui/src/{App.tsx => utils/index.ts} (68%)
delete mode 100644 airflow/utils/log/task_context_logger.py
rename airflow/www/templates/airflow/{dataset_next_run_modal.html =>
asset_next_run_modal.html} (97%)
rename airflow/www/templates/airflow/{datasets.html => assets.html} (100%)
create mode 100644 dev/breeze/doc/images/output_testing_task-sdk-tests.svg
create mode 100644 dev/breeze/doc/images/output_testing_task-sdk-tests.txt
copy providers/src/airflow/providers/edge/CHANGELOG.rst =>
docs/apache-airflow-providers-edge/cli-ref.rst (55%)
create mode 100644 docs/apache-airflow-providers-edge/edge_executor.rst
create mode 100644 newsfragments/42023.significant.rst
create mode 100644 newsfragments/42953.significant
create mode 100644 newsfragments/43067.significant.rst
create mode 100644 newsfragments/43096.significant.rst
create mode 100644 newsfragments/43183.significant.rst
delete mode 100644
providers/src/airflow/providers/amazon/aws/utils/asset_compat_lineage_collector.py
copy airflow/api_fastapi/main.py =>
providers/src/airflow/providers/edge/executors/__init__.py (89%)
create mode 100644
providers/src/airflow/providers/edge/executors/edge_executor.py
delete mode 100644
providers/src/airflow/providers/openlineage/utils/asset_compat_lineage_collector.py
create mode 100644
providers/tests/amazon/aws/sensors/test_sagemaker_processing.py
copy {airflow/api/auth => providers/tests/edge/executors}/__init__.py (100%)
create mode 100644 providers/tests/edge/executors/test_edge_executor.py
copy {airflow/api_connexion => tests/api_fastapi/core_api}/__init__.py (100%)
copy {airflow/api_connexion => tests/api_fastapi/core_api/routes}/__init__.py
(100%)
copy {airflow/api_connexion =>
tests/api_fastapi/core_api/routes/public}/__init__.py (100%)
rename tests/api_fastapi/{ => core_api}/routes/public/test_connections.py (99%)
rename tests/api_fastapi/{ => core_api}/routes/public/test_dag_run.py (99%)
rename tests/api_fastapi/{ => core_api}/routes/public/test_dags.py (81%)
rename tests/api_fastapi/{ => core_api}/routes/public/test_monitor.py (99%)
create mode 100644 tests/api_fastapi/core_api/routes/public/test_pools.py
create mode 100644 tests/api_fastapi/core_api/routes/public/test_providers.py
rename tests/api_fastapi/{ => core_api}/routes/public/test_variables.py (85%)
copy {airflow/api_connexion =>
tests/api_fastapi/core_api/routes/ui}/__init__.py (100%)
rename tests/api_fastapi/{ => core_api}/routes/ui/test_assets.py (96%)
rename tests/api_fastapi/{ => core_api}/routes/ui/test_dashboard.py (95%)
copy {airflow/api_connexion => tests/api_fastapi/execution_api}/__init__.py
(100%)
copy {airflow/api_connexion =>
tests/api_fastapi/execution_api/routes}/__init__.py (100%)
copy airflow/api_fastapi/main.py =>
tests/api_fastapi/execution_api/routes/test_health.py (82%)
delete mode 100644 tests/api_fastapi/routes/__init__.py
delete mode 100644 tests/api_fastapi/routes/public/__init__.py
delete mode 100644 tests/api_fastapi/routes/ui/__init__.py
create mode 100644 tests/api_fastapi/test_app.py
delete mode 100644 tests/utils/log/test_task_context_logger.py
copy airflow/api_fastapi/main.py => tests_common/test_utils/log_handlers.py
(89%)
