This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch reintro-venv-task-supervisor
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 9756bb04cd3 fixup! Support for "reconnecting" Supervisor Comms from
task process when `dag.test()` are used
discard fcbecdc7918 Support for "reconnecting" Supervisor Comms from task
process when `dag.test()` are used
add 102b262db40 Further fixes for release preparation process for tarballs
(#57996)
add 283b86bf3bb Remove unnecessary `--tag` flag from git push (#57999)
add 37c379582b1 Use VERSION_SUFFIX in airflow-ctl when preparing PyPI
packages. (#58001)
add f5e202733e8 build: upgrade ruff to 0.14.4 (#58017)
add 4e2792208c2 Expanding task sdk integration tests to test few dagrun
operations (#57955)
add 8fe6c1c5682 Adjustments in release docs (#58008)
add 74ea291283b Fix Connection test failures due to Fernet key caching
(#58034)
add 20146e543bc fix: Add .txt extension for log download function (#57991)
add 62a73b164aa Fix double redirection while authenticating in Fab auth
manager (#57993)
add 7fed3901c32 Migrate FAB GET /roles/{name} to FastAPI (#58009)
add 0117e77b108 Fix mypy type errors in test_taskinstance.py (#57942)
add e95748a964e Fix logout in airflow-core (#57990)
add 687f062f2d1 Enable PT006 rule to microsoft Provider test(hooks)
(#57932)
add 518be181956 Enable PT006 rule to ssh Provider test (#57929)
add 63587d2cdad Enable PT006 rule to microsoft Provider test(log,sensors)
(#57927)
add 5717cc82a54 Enable PT006 rule to samba Provider test(transfers, hooks)
(#57926)
add d7722e42027 Enable PT006 rule to microsoft Provider test(transfers)
(#57925)
add 5616b19966b PT006 modify standard (operator) (#58020)
add dc5c6b2fd8b Enable PT006 rule to standard Provider test(decorator,
hook) 8 files (#58019)
add ba9b8946d53 Enable PT006 rule to 6 files in providers (edge3,git)
(#58018)
add 138eddfa8bc modify all remaining files related to airflow-core (#58015)
add 1b39eaf6991 Enable PT006 rule to airflow-core tests (auth, common,
always, integration) (#58014)
add 682a50e80f6 modify route/public (#58012)
add ee6dc199e16 Enable PT006 rule to airflow-core tests (route/ui,
execution_api) (#58010)
add 2e909034354 Enable PT006 rule to airflow-core tests (cli) (#58007)
add 571e03f2a53 Enable PT006 rule to 23 files in providers (all remaining
files related to amazon) (#58005)
add c09e3f92d31 Enable PT006 rule to 23 files in providers (amazon ->
hooks, links, log, queues) (#58003)
add 468d2f25d46 Fix logout in Fab and Keycloak auth managers (#57992)
add 76d71783839 Stubbing missing tests for task sdk integration testing
for xcoms (#58031)
add d9a3b2c1d0d Stubbing missing tests for task sdk integration testing
for variables (#58030)
add e6d650bac62 Stubbing missing tests for task sdk integration testing
for connection (#58029)
add d1a4c0c056a Stubbing missing tests for task sdk integration testing
for dagruns (#58036)
add 816d3dc233a Docs: Add note on running prek inside Breeze (#58039)
add db0260d00be Update Arabic translation 2025-11-07 (#58042)
add 58a2abd912b Add number of queries guard for ui team (#57980)
add 56ddebe108c Add number of queries guard for ui grid (#57977)
add 7594818de51 fix typos in comments within triggerer_job_runner.py
(#58013)
add f5789979b9c Update Hebrew translation 2025-11-07 (#58041)
add e4f9fef36e8 Add number of queries guard for ui calendar (#58044)
add 63a8f549f2a Enable PT006 rule to 14 files in providers
(databricks,dbt,docker) (#57994)
add 4d7c077e450 Enable PT006 rule to sftp Provider test (#57924)
add a533af5f788 Enable PT006 rule to microsoft Provider test(operators)
(#57928)
add 139a7846e85 Enable PT006 rule to postgres Provider test (#57934)
add 3a783ecf4c0 Enable PT006 rule to microsoft Provider
test(azure,mssql,psrp) (#57936)
add 08e09a25711 Enable PT006 rule to mysql Provider test (#57937)
add 884cbeb3a0f Enable PT006 rule to celery Provider test (#57938)
add c684cb67a3e Enable PT006 rule to neo4j Provider test (#57939)
add 5b9436bc419 Enable PT006 rule to openlineage Provider test (#57940)
add 5bb13eb8fcf Enable PT006 rule to oracle Provider test (#57941)
add ce90b46a921 Enable PT006 rule to google Provider test (operators
part2) (#57944)
add c3b19ac8cf5 Enable PT006 rule to google Provider test
(log,openlineage,common,utils) (#57947)
add 93f93035b5e Enable PT006 rule to airflow-core tests (core,
dag_processing) (#57948)
add 36b4545500a Enable PT006 rule to airflow-core tests (models) (#57949)
add ec669b977c6 Enable PT006 rule to google Provider test (triggers)
(#57950)
add c54baeadd58 Enable PT006 rule to airflow-core tests (models) (#57951)
add 094756a160f Enable PT006 rule to google Provider test (triggers)
(#57953)
add 5891dea5a8f Enable PT006 rule to slack Provider test (#57963)
add 62e896bc908 Enable PT006 rule to 19 files in providers (airbyte,
alibaba, atlassian, papermill, presto, redis, singularity, sqlite, tableau,
vertica, weaviate, elasticsearch, exasol) (#57986)
add a0138b4813a Enable PT006 rule to 19 files in providers (cncf,common)
(#57995)
add 92f35b14019 Enable PT006 rule to 13 files in providers (apache)
(#57998)
add 2c12bff3edd Enable PT006 rule to standard Provider test(ssensor,
trigge, util) 9 files (#58022)
add 7a69adf43c6 Add number of queries guard for ui next_run_assets (#58052)
add 2abece069ac fix MyPy type errors in datamodels/hitl.py (#57808)
add 3ba3c784040 Remove global from serialization (#57703)
add fc05e4bbe57 Enable PT006 rule to airflow-core tests (route/public)
(#58011)
add 8d0131c58fe Fix MyPy type errors in
api_fastapi(security.py),airflow/models(dag_version.py,hitl.py),mark_tasks.py
(#58054)
add e5cb168fafe Fix duplicated SQLAlchemy sessions caused transactions
fail to close (#57815)
add efa434ec27c feat: add resize function to dag run / TI notes (#57897)
add 2bf24964bec Fix broken canary, remove unneeded crypto key generation
(#58074)
add 8f15ec960bf Remove global from kerberos (#57702)
add 167669f075b Add test setup and example asset operation tests to task
SDK integration tests (#58027)
add 213294e573e Add number of queries guard for ui structure (#58051)
add ff219fead12 Expanding task sdk integration tests to test asset
operations (#58028)
add a4b3efd643b update CODEOWNERS (#58075)
add bfa9d5fe764 Fix reproducibility check source tarball instructions
(#58077)
add 83ebad00bc6 Remove global from settings part1 (#57705)
add d627b90e631 add doc line for hot reloading ui in certain wsl
environments (#57921)
add f64be4169fd Add learnings from Airflow 3 migration (#57989)
add c47c0817d8e Remove unused NullFernet from Crypto (#57988)
add bc3a750af47 Fix release cleanup for providers (#58082)
add 845e401a5ef Fix ts-compile-lint-ui hook not finding any UI files
(#58099)
add cbf94175a7f Update providers metadata 2025-11-08 (#58084)
add f4846a8706f The e2e-tests workflows properly use workflow-name to pass
name (#58100)
add 38021c2a46c Revert "Fix duplicated SQLAlchemy sessions caused
transactions fail to close (#57815)" (#58097)
add e7dfebfbba4 Revert "Remove unused NullFernet from Crypto (#57988)"
(#58107)
add 1f66c7fecf7 Upgrade hungarian language package (#58104)
add ac96487925a Add `executor.running_dags` gauge to expose count of
running DAGs (#12368) (#52815)
add 14c7fedef5a Components of providers docs update (#57657)
add a9fd899283a AIP-67 - Multi-team: Per team executor config (#57910)
add 4d596bcd08b Enable ruff PLW2101,PLW2901,PLW3301 rule (#57700)
add 7f53be7f43f Add registry.secretNames and registry.connections options
to Helm chart (#58094)
add 191e818663e Fix Python 3.13 RuntimeWarning in test_reading_from_pipes
(#58132)
add 4408d68a93b fix: Rendered Templates not showing dictionary items in
AF3 (#58071)
add e4a60ca7f85 Airflow documentation updates for Windows WSL2
installation (#57027)
add 0db5838f7ec fix: HITL params not validating (#57547)
add 9edf329a290 RFC: Close portuguese gap airflow 3.1 (#58119)
add ea89a908d7c close catalan gap (#58110)
add 7043f69fe45 Add CLI hot-reload support via --dev flag (#57741)
add 99883535ae1 Fix Connection test failures due to Fernet key caching
(#58137)
add 11fbd848a28 Convert all airflow distributions to be compliant with ASF
requirements (#58138)
add 197ef8cbe09 fix mypy errors in delete_dag.py (#58101)
add 691aa8fec1e close spanish gap airflow 3.1 (#58117)
add 096023d088d Update Release instruction to include Task SDK version
update (#58134)
add 7de7b7afe7a Updates the go-sdk/Justfile for the changed package layout
(#58153)
add 803cba597ff Remove deprecation warning in common test utils (#58152)
add e8c3e8393eb Support for "reconnecting" Supervisor Comms from task
process when `dag.test()` are used
add 3498a412707 fixup! Support for "reconnecting" Supervisor Comms from
task process when `dag.test()` are used
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 (9756bb04cd3)
\
N -- N -- N refs/heads/reintro-venv-task-supervisor (3498a412707)
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:
.github/CODEOWNERS | 26 +-
.github/workflows/airflow-e2e-tests.yml | 2 +-
.pre-commit-config.yaml | 2 +-
NOTICE | 5 +
RELEASE_NOTES.rst | 13 +-
.../logging-monitoring/metrics.rst | 1 +
airflow-core/docs/best-practices.rst | 2 +-
.../docs/installation/upgrading_to_airflow3.rst | 14 +-
airflow-core/docs/operators-and-hooks-ref.rst | 4 +-
airflow-core/docs/start.rst | 40 ++-
airflow-core/pyproject.toml | 5 +-
airflow-core/src/airflow/api/common/delete_dag.py | 10 +-
airflow-core/src/airflow/api/common/mark_tasks.py | 6 +-
.../api_fastapi/core_api/datamodels/hitl.py | 17 +-
.../api_fastapi/core_api/routes/public/auth.py | 17 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 6 +-
.../api_fastapi/core_api/routes/ui/structure.py | 3 +
.../src/airflow/api_fastapi/core_api/security.py | 2 +-
.../api_fastapi/core_api/services/public/pools.py | 4 +-
.../core_api/services/public/variables.py | 6 +-
.../api_fastapi/execution_api/datamodels/hitl.py | 5 +-
airflow-core/src/airflow/cli/cli_config.py | 5 +-
.../src/airflow/cli/commands/api_server_command.py | 2 +-
.../airflow/cli/commands/dag_processor_command.py | 9 +
.../src/airflow/cli/commands/scheduler_command.py | 6 +
.../src/airflow/cli/commands/triggerer_command.py | 9 +
airflow-core/src/airflow/cli/hot_reload.py | 197 +++++++++++++
.../src/airflow/config_templates/config.yml | 8 +
airflow-core/src/airflow/configuration.py | 4 +
.../src/airflow/dag_processing/collection.py | 4 +-
.../src/airflow/executors/executor_loader.py | 10 +-
.../src/airflow/jobs/scheduler_job_runner.py | 13 +-
.../src/airflow/jobs/triggerer_job_runner.py | 6 +-
airflow-core/src/airflow/logging_config.py | 2 -
airflow-core/src/airflow/models/dag_version.py | 2 +
airflow-core/src/airflow/models/hitl.py | 2 +-
airflow-core/src/airflow/models/pool.py | 13 +-
.../src/airflow/models/renderedtifields.py | 43 ++-
airflow-core/src/airflow/security/kerberos.py | 9 +-
airflow-core/src/airflow/serialization/serde.py | 51 ++--
.../airflow/serialization/serialized_objects.py | 30 +-
airflow-core/src/airflow/settings.py | 46 ++--
.../airflow/ui/public/i18n/locales/ar/common.json | 7 +
.../ui/public/i18n/locales/ar/components.json | 12 +
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 2 +
.../airflow/ui/public/i18n/locales/ar/hitl.json | 5 +
.../airflow/ui/public/i18n/locales/ca/hitl.json | 2 +
.../airflow/ui/public/i18n/locales/es/common.json | 7 +
.../ui/public/i18n/locales/es/components.json | 6 +
.../src/airflow/ui/public/i18n/locales/es/dag.json | 2 +
.../airflow/ui/public/i18n/locales/es/hitl.json | 5 +
.../airflow/ui/public/i18n/locales/he/common.json | 7 +
.../ui/public/i18n/locales/he/components.json | 6 +
.../src/airflow/ui/public/i18n/locales/he/dag.json | 2 +
.../airflow/ui/public/i18n/locales/he/hitl.json | 5 +
.../airflow/ui/public/i18n/locales/hu/common.json | 18 +-
.../ui/public/i18n/locales/hu/components.json | 4 +
.../src/airflow/ui/public/i18n/locales/hu/dag.json | 5 +
.../airflow/ui/public/i18n/locales/hu/hitl.json | 8 +
.../airflow/ui/public/i18n/locales/pt/common.json | 7 +
.../ui/public/i18n/locales/pt/components.json | 8 +
.../src/airflow/ui/public/i18n/locales/pt/dag.json | 2 +
.../airflow/ui/public/i18n/locales/pt/hitl.json | 5 +
.../ui/src/components/DisplayMarkdownButton.tsx | 6 +-
.../ui/src/components/EditableMarkdownArea.tsx | 7 +-
.../ui/src/components/EditableMarkdownButton.tsx | 55 ++--
.../ui/src/components/ui/ResizableWrapper.tsx | 2 +
.../src/airflow/ui/src/layouts/Nav/LogoutModal.tsx | 1 -
.../ui/src/layouts/Nav/TimezoneMenuItem.tsx | 4 +-
.../ui/src/pages/TaskInstance/Logs/Logs.tsx | 2 +-
airflow-core/src/airflow/ui/src/utils/hitl.ts | 51 ++--
airflow-core/src/airflow/ui/src/utils/query.ts | 2 +-
airflow-core/src/airflow/utils/cli.py | 7 +
.../cli/commands/test_celery_command.py | 2 +-
.../tests/integration/security/test_kerberos.py | 2 +-
airflow-core/tests/unit/always/test_connection.py | 14 +-
.../tests/unit/always/test_providers_manager.py | 2 +-
.../tests/unit/always/test_secrets_backends.py | 2 +-
.../unit/always/test_secrets_local_filesystem.py | 30 +-
.../managers/simple/test_simple_auth_manager.py | 16 +-
.../auth/managers/test_base_auth_manager.py | 18 +-
.../tests/unit/api_fastapi/auth/test_tokens.py | 2 +-
.../unit/api_fastapi/common/test_exceptions.py | 4 +-
.../core_api/routes/public/test_assets.py | 20 +-
.../core_api/routes/public/test_auth.py | 13 +-
.../core_api/routes/public/test_backfills.py | 10 +-
.../core_api/routes/public/test_config.py | 8 +-
.../core_api/routes/public/test_connections.py | 16 +-
.../core_api/routes/public/test_dag_run.py | 40 +--
.../core_api/routes/public/test_dag_stats.py | 2 +-
.../core_api/routes/public/test_dag_tags.py | 2 +-
.../core_api/routes/public/test_dag_versions.py | 10 +-
.../core_api/routes/public/test_dag_warning.py | 2 +-
.../core_api/routes/public/test_dags.py | 45 ++-
.../core_api/routes/public/test_event_logs.py | 4 +-
.../core_api/routes/public/test_extra_links.py | 2 +-
.../core_api/routes/public/test_hitl.py | 8 +-
.../core_api/routes/public/test_import_error.py | 6 +-
.../api_fastapi/core_api/routes/public/test_job.py | 2 +-
.../api_fastapi/core_api/routes/public/test_log.py | 6 +-
.../core_api/routes/public/test_plugins.py | 2 +-
.../core_api/routes/public/test_pools.py | 16 +-
.../core_api/routes/public/test_providers.py | 2 +-
.../core_api/routes/public/test_task_instances.py | 68 ++---
.../core_api/routes/public/test_variables.py | 12 +-
.../core_api/routes/public/test_xcom.py | 12 +-
.../api_fastapi/core_api/routes/ui/test_assets.py | 4 +-
.../core_api/routes/ui/test_backfills.py | 2 +-
.../core_api/routes/ui/test_calendar.py | 11 +-
.../api_fastapi/core_api/routes/ui/test_dags.py | 6 +-
.../core_api/routes/ui/test_dashboard.py | 2 +-
.../core_api/routes/ui/test_dependencies.py | 2 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 82 ++++--
.../core_api/routes/ui/test_structure.py | 17 +-
.../api_fastapi/core_api/routes/ui/test_teams.py | 4 +-
.../services/public/test_task_instances.py | 8 +-
.../unit/api_fastapi/core_api/test_security.py | 6 +-
.../versions/head/test_asset_events.py | 14 +-
.../execution_api/versions/head/test_hitl.py | 2 +-
.../versions/head/test_task_instances.py | 27 +-
.../execution_api/versions/head/test_variables.py | 10 +-
.../execution_api/versions/head/test_xcoms.py | 6 +-
.../versions/v2025_04_28/test_task_instances.py | 2 +-
.../versions/v2025_04_28/test_xcom.py | 2 +-
airflow-core/tests/unit/api_fastapi/test_app.py | 2 +-
airflow-core/tests/unit/assets/test_evaluation.py | 8 +-
.../tests/unit/callbacks/test_callback_requests.py | 4 +-
airflow-core/tests/unit/charts/log_groomer.py | 4 +-
.../unit/cli/commands/test_api_server_command.py | 4 +-
.../unit/cli/commands/test_backfill_command.py | 2 +-
.../tests/unit/cli/commands/test_config_command.py | 4 +-
.../unit/cli/commands/test_connection_command.py | 10 +-
.../cli/commands/test_dag_processor_command.py | 11 +
.../tests/unit/cli/commands/test_db_command.py | 36 +--
.../tests/unit/cli/commands/test_info_command.py | 2 +-
.../unit/cli/commands/test_scheduler_command.py | 12 +-
.../unit/cli/commands/test_triggerer_command.py | 11 +
.../unit/cli/commands/test_variable_command.py | 2 +-
airflow-core/tests/unit/cli/test_cli_parser.py | 24 +-
airflow-core/tests/unit/cli/test_hot_reload.py | 100 +++++++
airflow-core/tests/unit/core/test_configuration.py | 25 +-
.../tests/unit/core/test_example_dags_system.py | 2 +-
.../tests/unit/core/test_impersonation_tests.py | 5 +-
airflow-core/tests/unit/core/test_settings.py | 2 +-
airflow-core/tests/unit/core/test_stats.py | 6 +-
.../tests/unit/dag_processing/bundles/test_base.py | 4 +-
.../bundles/test_dag_bundle_manager.py | 2 +-
.../tests/unit/dag_processing/test_collection.py | 6 +-
.../tests/unit/dag_processing/test_dagbag.py | 4 +-
.../tests/unit/dag_processing/test_manager.py | 8 +-
.../tests/unit/dag_processing/test_processor.py | 8 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 23 ++
airflow-core/tests/unit/models/test_asset.py | 2 +-
airflow-core/tests/unit/models/test_backfill.py | 2 +-
airflow-core/tests/unit/models/test_callback.py | 4 +-
airflow-core/tests/unit/models/test_cleartasks.py | 10 +-
airflow-core/tests/unit/models/test_connection.py | 28 +-
airflow-core/tests/unit/models/test_dag.py | 24 +-
airflow-core/tests/unit/models/test_dagrun.py | 22 +-
airflow-core/tests/unit/models/test_deadline.py | 6 +-
.../tests/unit/models/test_mappedoperator.py | 50 ++--
.../tests/unit/models/test_renderedtifields.py | 76 ++++-
.../tests/unit/models/test_serialized_dag.py | 2 +-
.../tests/unit/models/test_taskinstance.py | 29 +-
airflow-core/tests/unit/models/test_trigger.py | 2 +-
airflow-core/tests/unit/models/test_variable.py | 2 +-
airflow-core/tests/unit/models/test_xcom.py | 4 +-
airflow-core/tests/unit/models/test_xcom_arg.py | 2 +-
.../tests/unit/plugins/test_plugin_ignore.py | 8 +-
airflow-core/tests/unit/security/test_kerberos.py | 11 +-
.../unit/serialization/test_serialized_objects.py | 2 +
airflow-core/tests/unit/utils/test_cli_util.py | 28 ++
{clients/python => airflow-ctl}/LICENSE | 0
airflow-ctl/NOTICE | 5 +
airflow-ctl/pyproject.toml | 2 +
chart/NOTICE | 2 +-
chart/docs/conf.py | 5 +-
chart/docs/production-guide.rst | 6 +-
chart/files/pod-template-file.kubernetes-helm-yaml | 5 +-
chart/newsfragments/57615.misc.rst | 1 +
chart/pyproject.toml | 1 -
chart/templates/_helpers.yaml | 16 +-
.../api-server/api-server-deployment.yaml | 5 +-
chart/templates/cleanup/cleanup-cronjob.yaml | 5 +-
.../dag-processor/dag-processor-deployment.yaml | 5 +-
chart/templates/flower/flower-deployment.yaml | 5 +-
chart/templates/jobs/create-user-job.yaml | 5 +-
chart/templates/jobs/migrate-database-job.yaml | 5 +-
.../templates/pgbouncer/pgbouncer-deployment.yaml | 5 +-
chart/templates/redis/redis-statefulset.yaml | 5 +-
.../templates/scheduler/scheduler-deployment.yaml | 5 +-
chart/templates/secrets/registry-secret.yaml | 2 +-
chart/templates/statsd/statsd-deployment.yaml | 5 +-
.../templates/triggerer/triggerer-deployment.yaml | 5 +-
.../templates/webserver/webserver-deployment.yaml | 5 +-
chart/templates/workers/worker-deployment.yaml | 5 +-
chart/values.schema.json | 21 +-
chart/values.yaml | 11 +-
clients/python/pyproject.toml | 4 +-
contributing-docs/15_node_environment_setup.rst | 2 +
dev/README_RELEASE_AIRFLOW.md | 134 +++++----
dev/README_RELEASE_AIRFLOWCTL.md | 64 ++---
dev/airflow-license | 4 +-
dev/breeze/doc/03_developer_tasks.rst | 11 +
.../output_release-management_prepare-tarball.svg | 44 +--
.../output_release-management_prepare-tarball.txt | 2 +-
dev/breeze/pyproject.toml | 1 -
.../commands/release_candidate_command.py | 22 +-
.../commands/release_management_commands.py | 8 +-
.../commands/release_management_commands_config.py | 2 +-
dev/breeze/src/airflow_breeze/global_constants.py | 6 +-
.../templates/pyproject_TEMPLATE.toml.jinja2 | 3 +-
.../airflow_breeze/utils/add_back_references.py | 4 +-
.../utils/constraints_version_check.py | 4 +-
.../src/airflow_breeze/utils/gh_workflow_utils.py | 8 +-
dev/breeze/src/airflow_breeze/utils/packages.py | 7 +
.../utils/projects_google_spreadsheet.py | 4 +-
dev/breeze/uv.lock | 18 +-
dev/chart/build_changelog_annotations.py | 4 +-
dev/check_files.py | 6 +-
devel-common/pyproject.toml | 2 +-
.../src/sphinx_exts/operators_and_hooks_ref.py | 4 +-
.../src/sphinx_exts/substitution_extensions.py | 4 +-
.../tests_common/_internals/forbidden_warnings.py | 4 +-
devel-common/src/tests_common/pytest_plugin.py | 4 +-
.../src/tests_common/test_utils/version_compat.py | 1 +
docker-stack-docs/pyproject.toml | 1 -
generated/provider_metadata.json | 156 ++++++-----
go-sdk/Justfile | 4 +-
LICENSE => go-sdk/LICENSE | 0
go-sdk/NOTICE | 5 +
go-sdk/pkg/logging/server/server.go | 2 +-
.../helm_tests/airflow_aux/test_airflow_common.py | 59 ++++
providers-summary-docs/pyproject.toml | 1 -
LICENSE => providers/airbyte/LICENSE | 0
providers/airbyte/NOTICE | 5 +
providers/airbyte/pyproject.toml | 3 +-
.../tests/unit/airbyte/triggers/test_airbyte.py | 10 +-
LICENSE => providers/alibaba/LICENSE | 0
providers/alibaba/NOTICE | 5 +
providers/alibaba/pyproject.toml | 3 +-
.../unit/alibaba/cloud/links/test_maxcompute.py | 2 +-
.../alibaba/cloud/log/test_oss_task_handler.py | 2 +-
LICENSE => providers/amazon/LICENSE | 0
providers/amazon/NOTICE | 5 +
providers/amazon/pyproject.toml | 3 +-
.../airflow/providers/amazon/aws/hooks/athena.py | 8 +-
.../amazon/aws/secrets/secrets_manager.py | 7 +-
.../amazon/aws/transfers/dynamodb_to_s3.py | 4 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 7 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 4 +-
.../aws/auth_manager/test_aws_auth_manager.py | 22 +-
.../aws/executors/batch/test_batch_executor.py | 2 +-
.../unit/amazon/aws/executors/batch/test_utils.py | 2 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 13 +-
.../utils/test_exponential_backoff_retry.py | 4 +-
.../tests/unit/amazon/aws/hooks/test_athena_sql.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 20 +-
.../unit/amazon/aws/hooks/test_batch_client.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_bedrock.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_datasync.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_dynamodb.py | 4 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ecr.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_eks.py | 6 +-
.../unit/amazon/aws/hooks/test_hooks_signature.py | 8 +-
.../amazon/aws/hooks/test_kinesis_analytics.py | 2 +-
.../unit/amazon/aws/hooks/test_lambda_function.py | 4 +-
.../tests/unit/amazon/aws/hooks/test_logs.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_quicksight.py | 12 +-
.../unit/amazon/aws/hooks/test_redshift_data.py | 8 +-
.../unit/amazon/aws/hooks/test_redshift_sql.py | 6 +-
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 16 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ssm.py | 2 +-
.../tests/unit/amazon/aws/links/test_base_aws.py | 2 +-
.../amazon/tests/unit/amazon/aws/links/test_emr.py | 4 +-
.../unit/amazon/aws/links/test_step_function.py | 4 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 4 +-
.../unit/amazon/aws/log/test_s3_task_handler.py | 2 +-
.../unit/amazon/aws/operators/test_appflow.py | 1 -
.../aws/operators/test_sagemaker_processing.py | 6 +-
.../aws/operators/test_sagemaker_transform.py | 6 +-
.../tests/unit/amazon/aws/queues/test_sqs.py | 2 +-
.../amazon/aws/secrets/test_secrets_manager.py | 6 +-
.../amazon/aws/secrets/test_systems_manager.py | 6 +-
.../tests/unit/amazon/aws/sensors/test_batch.py | 2 +-
.../unit/amazon/aws/sensors/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ecs.py | 16 +-
.../aws/sensors/test_emr_serverless_application.py | 2 +-
.../amazon/aws/sensors/test_emr_serverless_job.py | 2 +-
.../amazon/aws/sensors/test_lambda_function.py | 2 +-
.../aws/sensors/test_opensearch_serverless.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_s3.py | 8 +-
.../unit/amazon/aws/system/utils/test_helpers.py | 4 +-
.../amazon/aws/transfers/test_redshift_to_s3.py | 20 +-
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 16 +-
.../aws/triggers/test_opensearch_serverless.py | 2 +-
.../unit/amazon/aws/triggers/test_redshift_data.py | 4 +-
.../amazon/aws/utils/test_connection_wrapper.py | 10 +-
.../unit/amazon/aws/utils/test_eks_get_token.py | 2 +-
.../tests/unit/amazon/aws/utils/test_waiter.py | 2 +-
LICENSE => providers/apache/beam/LICENSE | 0
providers/apache/beam/NOTICE | 5 +
providers/apache/beam/pyproject.toml | 3 +-
.../airflow/providers/apache/beam/hooks/beam.py | 4 +-
.../beam/tests/unit/apache/beam/hooks/test_beam.py | 8 +-
.../tests/unit/apache/beam/operators/test_beam.py | 2 +-
LICENSE => providers/apache/cassandra/LICENSE | 0
providers/apache/cassandra/NOTICE | 5 +
providers/apache/cassandra/pyproject.toml | 3 +-
LICENSE => providers/apache/drill/LICENSE | 0
providers/apache/drill/NOTICE | 5 +
providers/apache/drill/pyproject.toml | 3 +-
.../tests/unit/apache/drill/hooks/test_drill.py | 4 +-
LICENSE => providers/apache/druid/LICENSE | 0
providers/apache/druid/NOTICE | 5 +
providers/apache/druid/pyproject.toml | 3 +-
.../tests/unit/apache/druid/hooks/test_druid.py | 2 +-
LICENSE => providers/apache/flink/LICENSE | 0
providers/apache/flink/NOTICE | 5 +
providers/apache/flink/pyproject.toml | 3 +-
LICENSE => providers/apache/hdfs/LICENSE | 0
providers/apache/hdfs/NOTICE | 5 +
providers/apache/hdfs/pyproject.toml | 3 +-
.../tests/unit/apache/hdfs/hooks/test_webhdfs.py | 2 +-
.../unit/apache/hdfs/log/test_hdfs_task_handler.py | 2 +-
LICENSE => providers/apache/hive/LICENSE | 0
providers/apache/hive/NOTICE | 5 +
providers/apache/hive/pyproject.toml | 3 +-
.../airflow/providers/apache/hive/hooks/hive.py | 29 +-
.../hive/tests/unit/apache/hive/hooks/test_hive.py | 6 +-
LICENSE => providers/apache/iceberg/LICENSE | 0
providers/apache/iceberg/NOTICE | 5 +
providers/apache/iceberg/pyproject.toml | 3 +-
LICENSE => providers/apache/impala/LICENSE | 0
providers/apache/impala/NOTICE | 5 +
providers/apache/impala/pyproject.toml | 3 +-
.../unit/apache/impala/hooks/test_impala_sql.py | 4 +-
LICENSE => providers/apache/kafka/LICENSE | 0
providers/apache/kafka/NOTICE | 5 +
providers/apache/kafka/pyproject.toml | 3 +-
.../unit/apache/kafka/operators/test_consume.py | 6 +-
.../tests/unit/apache/kafka/queues/test_kafka.py | 8 +-
LICENSE => providers/apache/kylin/LICENSE | 0
providers/apache/kylin/NOTICE | 5 +
providers/apache/kylin/pyproject.toml | 3 +-
LICENSE => providers/apache/livy/LICENSE | 0
providers/apache/livy/NOTICE | 5 +
providers/apache/livy/pyproject.toml | 3 +-
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 2 +-
LICENSE => providers/apache/pig/LICENSE | 0
providers/apache/pig/NOTICE | 5 +
providers/apache/pig/pyproject.toml | 3 +-
LICENSE => providers/apache/pinot/LICENSE | 0
providers/apache/pinot/NOTICE | 5 +
providers/apache/pinot/pyproject.toml | 3 +-
LICENSE => providers/apache/spark/LICENSE | 0
providers/apache/spark/NOTICE | 5 +
providers/apache/spark/pyproject.toml | 3 +-
.../providers/apache/spark/hooks/spark_submit.py | 8 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 2 +-
LICENSE => providers/apache/tinkerpop/LICENSE | 0
providers/apache/tinkerpop/NOTICE | 5 +
providers/apache/tinkerpop/pyproject.toml | 3 +-
.../unit/apache/tinkerpop/hooks/test_gremlin.py | 6 +-
LICENSE => providers/apprise/LICENSE | 0
providers/apprise/NOTICE | 5 +
providers/apprise/pyproject.toml | 3 +-
LICENSE => providers/arangodb/LICENSE | 0
providers/arangodb/NOTICE | 5 +
providers/arangodb/pyproject.toml | 3 +-
LICENSE => providers/asana/LICENSE | 0
providers/asana/NOTICE | 5 +
providers/asana/pyproject.toml | 3 +-
LICENSE => providers/atlassian/jira/LICENSE | 0
providers/atlassian/jira/NOTICE | 5 +
providers/atlassian/jira/pyproject.toml | 3 +-
.../tests/unit/atlassian/jira/hooks/test_jira.py | 4 +-
LICENSE => providers/celery/LICENSE | 0
providers/celery/NOTICE | 5 +
providers/celery/pyproject.toml | 3 +-
.../unit/celery/executors/test_celery_executor.py | 2 +-
.../executors/test_celery_kubernetes_executor.py | 4 +-
LICENSE => providers/cloudant/LICENSE | 0
providers/cloudant/NOTICE | 5 +
providers/cloudant/pyproject.toml | 3 +-
LICENSE => providers/cncf/kubernetes/LICENSE | 0
providers/cncf/kubernetes/NOTICE | 5 +
providers/cncf/kubernetes/pyproject.toml | 3 +-
.../kubernetes/decorators/test_kubernetes_cmd.py | 4 +-
.../decorators/test_kubernetes_commons.py | 2 +-
.../executors/test_kubernetes_executor.py | 10 +-
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 28 +-
.../kubernetes/log_handlers/test_log_handlers.py | 2 +-
.../unit/cncf/kubernetes/operators/test_job.py | 10 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 30 +-
.../kubernetes/operators/test_spark_kubernetes.py | 6 +-
.../kubernetes/test_kubernetes_helper_functions.py | 6 +-
.../unit/cncf/kubernetes/test_pod_generator.py | 10 +-
.../unit/cncf/kubernetes/triggers/test_pod.py | 6 +-
.../unit/cncf/kubernetes/utils/test_container.py | 6 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 24 +-
LICENSE => providers/cohere/LICENSE | 0
providers/cohere/NOTICE | 5 +
providers/cohere/pyproject.toml | 3 +-
LICENSE => providers/common/compat/LICENSE | 0
providers/common/compat/NOTICE | 5 +
providers/common/compat/pyproject.toml | 3 +-
.../tests/unit/common/compat/test__compat_utils.py | 8 +-
LICENSE => providers/common/io/LICENSE | 0
providers/common/io/NOTICE | 5 +
providers/common/io/pyproject.toml | 3 +-
.../io/tests/unit/common/io/xcom/test_backend.py | 2 +-
LICENSE => providers/common/messaging/LICENSE | 0
providers/common/messaging/NOTICE | 5 +
providers/common/messaging/pyproject.toml | 3 +-
LICENSE => providers/common/sql/LICENSE | 0
providers/common/sql/NOTICE | 5 +
providers/common/sql/pyproject.toml | 3 +-
.../sql/tests/unit/common/sql/hooks/test_sql.py | 14 +-
.../tests/unit/common/sql/hooks/test_sqlparse.py | 2 +-
.../tests/unit/common/sql/operators/test_sql.py | 4 +-
.../unit/common/sql/operators/test_sql_execute.py | 6 +-
LICENSE => providers/databricks/LICENSE | 0
providers/databricks/NOTICE | 5 +
providers/databricks/pyproject.toml | 3 +-
.../providers/databricks/hooks/databricks_sql.py | 2 +-
.../databricks/sensors/databricks_partition.py | 7 +-
.../tests/unit/databricks/hooks/test_databricks.py | 2 +-
.../unit/databricks/hooks/test_databricks_base.py | 4 +-
.../unit/databricks/hooks/test_databricks_sql.py | 19 +-
.../databricks/operators/test_databricks_sql.py | 4 +-
LICENSE => providers/datadog/LICENSE | 0
providers/datadog/NOTICE | 5 +
providers/datadog/pyproject.toml | 3 +-
LICENSE => providers/dbt/cloud/LICENSE | 0
providers/dbt/cloud/NOTICE | 5 +
providers/dbt/cloud/pyproject.toml | 3 +-
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 72 ++---
.../tests/unit/dbt/cloud/operators/test_dbt.py | 32 +--
.../cloud/tests/unit/dbt/cloud/sensors/test_dbt.py | 2 +-
.../tests/unit/dbt/cloud/triggers/test_dbt.py | 12 +-
.../tests/unit/dbt/cloud/utils/test_openlineage.py | 2 +-
LICENSE => providers/dingding/LICENSE | 0
providers/dingding/NOTICE | 5 +
providers/dingding/pyproject.toml | 3 +-
LICENSE => providers/discord/LICENSE | 0
providers/discord/NOTICE | 5 +
providers/discord/pyproject.toml | 3 +-
LICENSE => providers/docker/LICENSE | 0
providers/docker/NOTICE | 5 +
providers/docker/pyproject.toml | 3 +-
.../airflow/providers/docker/operators/docker.py | 4 +-
.../tests/unit/docker/decorators/test_docker.py | 2 +-
.../docker/tests/unit/docker/hooks/test_docker.py | 6 +-
.../tests/unit/docker/operators/test_docker.py | 6 +-
.../unit/docker/operators/test_docker_swarm.py | 4 +-
.../docker/tests/unit/docker/test_exceptions.py | 2 +-
LICENSE => providers/edge3/LICENSE | 0
providers/edge3/NOTICE | 5 +
providers/edge3/pyproject.toml | 3 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 6 +-
.../unit/edge3/executors/test_edge_executor.py | 2 +-
.../edge3/plugins/test_edge_executor_plugin.py | 2 +-
.../unit/edge3/worker_api/routes/test_worker.py | 4 +-
LICENSE => providers/elasticsearch/LICENSE | 0
providers/elasticsearch/NOTICE | 5 +
providers/elasticsearch/pyproject.toml | 3 +-
.../unit/elasticsearch/log/elasticmock/__init__.py | 5 +-
.../unit/elasticsearch/log/test_es_task_handler.py | 6 +-
LICENSE => providers/exasol/LICENSE | 0
providers/exasol/NOTICE | 5 +
providers/exasol/pyproject.toml | 3 +-
.../exasol/tests/unit/exasol/hooks/test_exasol.py | 4 +-
.../exasol/tests/unit/exasol/hooks/test_sql.py | 12 +-
.../tests/unit/exasol/operators/test_exasol_sql.py | 2 +-
LICENSE => providers/fab/LICENSE | 0
providers/fab/provider.yaml | 2 -
providers/fab/pyproject.toml | 5 +-
.../auth_manager/api_endpoints/user_endpoint.py | 4 +-
.../openapi/v2-fab-auth-manager-generated.yaml | 61 +++++
.../fab/auth_manager/api_fastapi/routes/login.py | 27 ++
.../fab/auth_manager/api_fastapi/routes/roles.py | 13 +
.../fab/auth_manager/api_fastapi/services/roles.py | 12 +
.../providers/fab/auth_manager/fab_auth_manager.py | 2 +-
.../fab/auth_manager/security_manager/override.py | 11 +-
.../fab/www/extensions/init_appbuilder.py | 3 +-
.../fab/src/airflow/providers/fab/www/views.py | 32 ++-
.../unit/fab/auth_manager/api_fastapi/conftest.py | 2 +-
.../auth_manager/api_fastapi/routes/test_login.py | 9 +
.../auth_manager/api_fastapi/routes/test_roles.py | 80 ++++++
.../api_fastapi/services/test_roles.py | 23 ++
.../auth_manager/cli_commands/test_role_command.py | 4 +-
.../auth_manager/cli_commands/test_user_command.py | 4 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 2 +-
providers/fab/www-hash.txt | 2 +-
LICENSE => providers/facebook/LICENSE | 0
providers/facebook/NOTICE | 5 +
providers/facebook/pyproject.toml | 3 +-
LICENSE => providers/ftp/LICENSE | 0
providers/ftp/NOTICE | 5 +
providers/ftp/pyproject.toml | 3 +-
LICENSE => providers/git/LICENSE | 0
providers/git/NOTICE | 5 +
providers/git/pyproject.toml | 3 +-
providers/git/tests/unit/git/bundles/test_git.py | 10 +-
providers/git/tests/unit/git/hooks/test_git.py | 2 +-
LICENSE => providers/github/LICENSE | 0
providers/github/NOTICE | 5 +
providers/github/pyproject.toml | 3 +-
LICENSE => providers/google/LICENSE | 0
providers/google/NOTICE | 5 +
providers/google/pyproject.toml | 3 +-
.../providers/google/3rd-party-licenses/NOTICE | 14 +-
.../providers/google/cloud/hooks/bigquery.py | 12 +-
.../providers/google/cloud/operators/translate.py | 4 +-
.../providers/google/cloud/transfers/sql_to_gcs.py | 16 +-
.../google/suite/transfers/sql_to_sheets.py | 9 +-
.../unit/google/cloud/log/test_gcs_task_handler.py | 2 +-
.../unit/google/cloud/openlineage/test_utils.py | 8 +-
.../unit/google/cloud/operators/test_datafusion.py | 2 +-
.../unit/google/cloud/operators/test_dataprep.py | 4 +-
.../unit/google/cloud/operators/test_functions.py | 12 +-
.../cloud/operators/test_kubernetes_engine.py | 13 +-
.../unit/google/cloud/operators/test_pubsub.py | 4 +-
.../unit/google/cloud/operators/test_spanner.py | 14 +-
.../google/cloud/operators/test_text_to_speech.py | 2 +-
.../cloud/transfers/test_bigquery_to_postgres.py | 3 +-
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 10 +-
.../google/cloud/transfers/test_gcs_to_sftp.py | 30 +-
.../google/cloud/transfers/test_mssql_to_gcs.py | 7 +-
.../google/cloud/transfers/test_mysql_to_gcs.py | 4 +-
.../google/cloud/transfers/test_oracle_to_gcs.py | 2 +-
.../google/cloud/transfers/test_postgres_to_gcs.py | 4 +-
.../unit/google/cloud/transfers/test_s3_to_gcs.py | 4 +-
.../google/cloud/transfers/test_sftp_to_gcs.py | 2 +-
.../google/cloud/transfers/test_trino_to_gcs.py | 2 +-
.../google/cloud/triggers/test_bigquery_dts.py | 2 +-
.../test_cloud_storage_transfer_service.py | 8 +-
.../unit/google/cloud/triggers/test_dataflow.py | 14 +-
.../tests/unit/google/cloud/triggers/test_gcs.py | 12 +-
.../cloud/triggers/test_kubernetes_engine.py | 2 +-
.../unit/google/cloud/triggers/test_vertex_ai.py | 2 +-
.../cloud/utils/test_credentials_provider.py | 4 +-
.../tests/unit/google/cloud/utils/test_dataform.py | 2 +-
.../unit/google/cloud/utils/test_datafusion.py | 2 +-
.../tests/unit/google/cloud/utils/test_dataproc.py | 2 +-
.../tests/unit/google/common/test_deprecated.py | 10 +-
LICENSE => providers/grpc/LICENSE | 0
providers/grpc/NOTICE | 5 +
providers/grpc/pyproject.toml | 3 +-
LICENSE => providers/hashicorp/LICENSE | 0
providers/hashicorp/NOTICE | 5 +
providers/hashicorp/pyproject.toml | 3 +-
LICENSE => providers/http/LICENSE | 0
providers/http/NOTICE | 5 +
providers/http/pyproject.toml | 3 +-
LICENSE => providers/imap/LICENSE | 0
providers/imap/NOTICE | 5 +
providers/imap/pyproject.toml | 3 +-
LICENSE => providers/influxdb/LICENSE | 0
providers/influxdb/NOTICE | 5 +
providers/influxdb/pyproject.toml | 3 +-
LICENSE => providers/jdbc/LICENSE | 0
providers/jdbc/NOTICE | 5 +
providers/jdbc/pyproject.toml | 3 +-
LICENSE => providers/jenkins/LICENSE | 0
providers/jenkins/NOTICE | 5 +
providers/jenkins/pyproject.toml | 3 +-
LICENSE => providers/keycloak/LICENSE | 0
providers/keycloak/NOTICE | 5 +
providers/keycloak/pyproject.toml | 3 +-
.../keycloak/auth_manager/keycloak_auth_manager.py | 4 +
.../v2-keycloak-auth-manager-generated.yaml | 33 +++
.../keycloak/auth_manager/routes/login.py | 38 ++-
.../unit/keycloak/auth_manager/routes/conftest.py | 27 +-
.../keycloak/auth_manager/routes/test_login.py | 38 +++
.../auth_manager/test_keycloak_auth_manager.py | 4 +
LICENSE => providers/microsoft/azure/LICENSE | 0
providers/microsoft/azure/NOTICE | 5 +
providers/microsoft/azure/pyproject.toml | 3 +-
.../tests/unit/microsoft/azure/hooks/test_adx.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_asb.py | 6 +-
.../unit/microsoft/azure/hooks/test_powerbi.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_wasb.py | 4 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 2 +-
.../unit/microsoft/azure/operators/test_asb.py | 6 +-
.../microsoft/azure/operators/test_data_factory.py | 4 +-
.../unit/microsoft/azure/operators/test_synapse.py | 2 +-
.../microsoft/azure/sensors/test_data_factory.py | 2 +-
.../azure/tests/unit/microsoft/azure/test_utils.py | 4 +-
.../microsoft/azure/transfers/test_s3_to_wasb.py | 6 +-
.../microsoft/azure/triggers/test_data_factory.py | 4 +-
LICENSE => providers/microsoft/mssql/LICENSE | 0
providers/microsoft/mssql/NOTICE | 5 +
providers/microsoft/mssql/pyproject.toml | 3 +-
.../tests/unit/microsoft/mssql/hooks/test_mssql.py | 2 +-
LICENSE => providers/microsoft/psrp/LICENSE | 0
providers/microsoft/psrp/NOTICE | 5 +
providers/microsoft/psrp/pyproject.toml | 3 +-
.../unit/microsoft/psrp/operators/test_psrp.py | 2 +-
LICENSE => providers/microsoft/winrm/LICENSE | 0
providers/microsoft/winrm/NOTICE | 5 +
providers/microsoft/winrm/pyproject.toml | 3 +-
LICENSE => providers/mongo/LICENSE | 0
providers/mongo/NOTICE | 5 +
providers/mongo/pyproject.toml | 3 +-
LICENSE => providers/mysql/LICENSE | 0
providers/mysql/NOTICE | 5 +
providers/mysql/pyproject.toml | 3 +-
.../providers/mysql/transfers/vertica_to_mysql.py | 6 +-
.../mysql/tests/unit/mysql/assets/test_mysql.py | 2 +-
.../mysql/tests/unit/mysql/hooks/test_mysql.py | 2 +-
LICENSE => providers/neo4j/LICENSE | 0
providers/neo4j/NOTICE | 5 +
providers/neo4j/pyproject.toml | 3 +-
.../neo4j/tests/unit/neo4j/hooks/test_neo4j.py | 4 +-
LICENSE => providers/odbc/LICENSE | 0
providers/odbc/NOTICE | 5 +
providers/odbc/pyproject.toml | 3 +-
LICENSE => providers/openai/LICENSE | 0
providers/openai/NOTICE | 5 +
providers/openai/pyproject.toml | 3 +-
LICENSE => providers/openfaas/LICENSE | 0
providers/openfaas/NOTICE | 5 +
providers/openfaas/pyproject.toml | 3 +-
LICENSE => providers/openlineage/LICENSE | 0
providers/openlineage/NOTICE | 5 +
providers/openlineage/pyproject.toml | 3 +-
.../src/airflow/providers/openlineage/utils/sql.py | 8 +-
.../tests/unit/openlineage/extractors/test_base.py | 2 +-
.../tests/unit/openlineage/operators/test_empty.py | 2 +-
.../tests/unit/openlineage/plugins/test_adapter.py | 2 +-
.../unit/openlineage/plugins/test_listener.py | 10 +-
.../unit/openlineage/plugins/test_openlineage.py | 2 +-
.../tests/unit/openlineage/utils/test_spark.py | 10 +-
.../tests/unit/openlineage/utils/test_sql.py | 2 +-
.../tests/unit/openlineage/utils/test_utils.py | 4 +-
LICENSE => providers/opensearch/LICENSE | 0
providers/opensearch/NOTICE | 5 +
providers/opensearch/pyproject.toml | 3 +-
LICENSE => providers/opsgenie/LICENSE | 0
providers/opsgenie/NOTICE | 5 +
providers/opsgenie/pyproject.toml | 3 +-
LICENSE => providers/oracle/LICENSE | 0
providers/oracle/NOTICE | 5 +
providers/oracle/pyproject.toml | 3 +-
.../oracle/tests/unit/oracle/hooks/test_oracle.py | 2 +-
LICENSE => providers/pagerduty/LICENSE | 0
providers/pagerduty/NOTICE | 5 +
providers/pagerduty/pyproject.toml | 3 +-
LICENSE => providers/papermill/LICENSE | 0
providers/papermill/NOTICE | 5 +
providers/papermill/pyproject.toml | 3 +-
.../unit/papermill/operators/test_papermill.py | 4 +-
LICENSE => providers/pgvector/LICENSE | 0
providers/pgvector/NOTICE | 5 +
providers/pgvector/pyproject.toml | 3 +-
LICENSE => providers/pinecone/LICENSE | 0
providers/pinecone/NOTICE | 5 +
providers/pinecone/pyproject.toml | 3 +-
LICENSE => providers/postgres/LICENSE | 0
providers/postgres/NOTICE | 5 +
providers/postgres/pyproject.toml | 3 +-
.../providers/postgres/dialects/postgres.py | 4 +-
.../tests/unit/postgres/assets/test_postgres.py | 2 +-
.../tests/unit/postgres/hooks/test_postgres.py | 8 +-
LICENSE => providers/presto/LICENSE | 0
providers/presto/NOTICE | 5 +
providers/presto/pyproject.toml | 3 +-
.../presto/tests/unit/presto/hooks/test_presto.py | 2 +-
.../tests/unit/presto/hooks/test_presto_sql.py | 11 +-
LICENSE => providers/qdrant/LICENSE | 0
providers/qdrant/NOTICE | 5 +
providers/qdrant/pyproject.toml | 3 +-
LICENSE => providers/redis/LICENSE | 0
providers/redis/NOTICE | 5 +
providers/redis/pyproject.toml | 3 +-
.../redis/tests/unit/redis/queues/test_redis.py | 2 +-
LICENSE => providers/salesforce/LICENSE | 0
providers/salesforce/NOTICE | 5 +
providers/salesforce/pyproject.toml | 3 +-
LICENSE => providers/samba/LICENSE | 0
providers/samba/NOTICE | 5 +
providers/samba/pyproject.toml | 3 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 2 +-
.../unit/samba/transfers/test_gcs_to_samba.py | 24 +-
LICENSE => providers/segment/LICENSE | 0
providers/segment/NOTICE | 5 +
providers/segment/pyproject.toml | 3 +-
LICENSE => providers/sendgrid/LICENSE | 0
providers/sendgrid/NOTICE | 5 +
providers/sendgrid/pyproject.toml | 3 +-
LICENSE => providers/sftp/LICENSE | 0
providers/sftp/NOTICE | 5 +
providers/sftp/pyproject.toml | 3 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 6 +-
.../sftp/tests/unit/sftp/operators/test_sftp.py | 4 +-
.../sftp/tests/unit/sftp/sensors/test_sftp.py | 4 +-
LICENSE => providers/singularity/LICENSE | 0
providers/singularity/NOTICE | 5 +
providers/singularity/pyproject.toml | 3 +-
.../unit/singularity/operators/test_singularity.py | 4 +-
LICENSE => providers/slack/LICENSE | 0
providers/slack/NOTICE | 5 +
providers/slack/pyproject.toml | 3 +-
.../slack/tests/unit/slack/hooks/test_slack.py | 6 +-
.../tests/unit/slack/hooks/test_slack_webhook.py | 6 +-
.../tests/unit/slack/notifications/test_slack.py | 2 +-
.../unit/slack/notifications/test_slack_webhook.py | 2 +-
.../slack/tests/unit/slack/operators/test_slack.py | 2 +-
.../unit/slack/operators/test_slack_webhook.py | 6 +-
.../unit/slack/transfers/test_sql_to_slack.py | 4 +-
.../slack/transfers/test_sql_to_slack_webhook.py | 4 +-
.../slack/tests/unit/slack/utils/test_utils.py | 4 +-
LICENSE => providers/smtp/LICENSE | 0
providers/smtp/NOTICE | 5 +
providers/smtp/pyproject.toml | 3 +-
LICENSE => providers/snowflake/LICENSE | 0
providers/snowflake/NOTICE | 5 +
providers/snowflake/pyproject.toml | 3 +-
LICENSE => providers/sqlite/LICENSE | 0
providers/sqlite/NOTICE | 5 +
providers/sqlite/pyproject.toml | 3 +-
.../sqlite/tests/unit/sqlite/hooks/test_sqlite.py | 2 +-
LICENSE => providers/ssh/LICENSE | 0
providers/ssh/NOTICE | 5 +
providers/ssh/pyproject.toml | 3 +-
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 2 +-
providers/ssh/tests/unit/ssh/operators/test_ssh.py | 6 +-
LICENSE => providers/standard/LICENSE | 0
providers/standard/NOTICE | 5 +
providers/standard/pyproject.toml | 3 +-
.../airflow/providers/standard/operators/hitl.py | 19 +-
.../airflow/providers/standard/triggers/hitl.py | 221 +++++++++------
.../airflow/providers/standard/version_compat.py | 1 +
.../tests/unit/standard/decorators/test_bash.py | 14 +-
.../decorators/test_branch_external_python.py | 2 +-
.../unit/standard/decorators/test_branch_python.py | 2 +-
.../standard/decorators/test_branch_virtualenv.py | 2 +-
.../tests/unit/standard/decorators/test_python.py | 2 +-
.../standard/decorators/test_python_virtualenv.py | 6 +-
.../unit/standard/decorators/test_short_circuit.py | 4 +-
.../tests/unit/standard/hooks/test_subprocess.py | 4 +-
.../tests/unit/standard/operators/test_bash.py | 6 +-
.../tests/unit/standard/operators/test_datetime.py | 6 +-
.../tests/unit/standard/operators/test_hitl.py | 144 ++++++++--
.../tests/unit/standard/operators/test_python.py | 20 +-
.../unit/standard/operators/test_trigger_dagrun.py | 6 +-
.../tests/unit/standard/operators/test_weekday.py | 2 +-
.../tests/unit/standard/sensors/test_date_time.py | 6 +-
.../standard/sensors/test_external_task_sensor.py | 10 +-
.../tests/unit/standard/sensors/test_time.py | 4 +-
.../unit/standard/triggers/test_external_task.py | 11 +-
.../tests/unit/standard/triggers/test_hitl.py | 36 ++-
.../tests/unit/standard/triggers/test_temporal.py | 2 +-
.../unit/standard/utils/test_python_virtualenv.py | 2 +-
.../unit/standard/utils/test_sensor_helper.py | 2 +-
.../tests/unit/standard/utils/test_skipmixin.py | 4 +-
.../tests/unit/standard/utils/test_weekday.py | 4 +-
LICENSE => providers/tableau/LICENSE | 0
providers/tableau/NOTICE | 5 +
providers/tableau/pyproject.toml | 3 +-
.../tests/unit/tableau/hooks/test_tableau.py | 2 +-
LICENSE => providers/telegram/LICENSE | 0
providers/telegram/NOTICE | 5 +
providers/telegram/pyproject.toml | 3 +-
LICENSE => providers/teradata/LICENSE | 0
providers/teradata/NOTICE | 5 +
providers/teradata/pyproject.toml | 3 +-
LICENSE => providers/trino/LICENSE | 0
providers/trino/NOTICE | 5 +
providers/trino/pyproject.toml | 3 +-
LICENSE => providers/vertica/LICENSE | 0
providers/vertica/NOTICE | 5 +
providers/vertica/pyproject.toml | 3 +-
.../tests/unit/vertica/hooks/test_vertica_sql.py | 2 +-
LICENSE => providers/weaviate/LICENSE | 0
providers/weaviate/NOTICE | 5 +
providers/weaviate/pyproject.toml | 3 +-
.../tests/unit/weaviate/hooks/test_weaviate.py | 6 +-
LICENSE => providers/yandex/LICENSE | 0
providers/yandex/NOTICE | 5 +
providers/yandex/pyproject.toml | 3 +-
LICENSE => providers/ydb/LICENSE | 0
providers/ydb/NOTICE | 5 +
providers/ydb/pyproject.toml | 3 +-
LICENSE => providers/zendesk/LICENSE | 0
providers/zendesk/NOTICE | 5 +
providers/zendesk/pyproject.toml | 3 +-
pyproject.toml | 7 +-
reproducible_build.yaml | 4 +-
.../ci/prek/check_common_compat_lazy_imports.py | 2 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_provider_version_compat.py | 7 +-
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/sort_in_the_wild.py | 8 +-
scripts/ci/prek/ts_compile_lint_ui.py | 4 +-
.../in_container/install_airflow_and_providers.py | 8 +-
.../in_container/run_capture_airflowctl_help.py | 4 +-
.../dags/test_asset_dag.py | 35 ++-
task-sdk-tests/tests/task_sdk_tests/conftest.py | 305 ++++++++++++++++-----
.../task_sdk_tests/test_asset_event_operations.py | 66 +++++
.../tests/task_sdk_tests/test_asset_operations.py | 65 +++++
.../task_sdk_tests/test_connection_operations.py | 14 +
.../task_sdk_tests/test_dag_run_operations.py | 120 ++++++++
.../task_sdk_tests/test_variable_operations.py | 26 ++
.../tests/task_sdk_tests/test_xcom_operations.py | 74 +++++
task-sdk/NOTICE | 5 +
task-sdk/pyproject.toml | 4 +-
task-sdk/src/airflow/sdk/api/client.py | 2 +-
task-sdk/src/airflow/sdk/bases/operator.py | 6 +-
task-sdk/src/airflow/sdk/definitions/param.py | 1 -
task-sdk/src/airflow/sdk/execution_time/context.py | 18 +-
task-sdk/tests/conftest.py | 2 +-
.../tests/task_sdk/execution_time/test_hitl.py | 4 +-
.../task_sdk/execution_time/test_supervisor.py | 20 ++
.../task_sdk/execution_time/test_task_runner.py | 8 +-
818 files changed, 4823 insertions(+), 2011 deletions(-)
create mode 100644 NOTICE
create mode 100644 airflow-core/src/airflow/cli/hot_reload.py
create mode 100644 airflow-core/tests/unit/cli/test_hot_reload.py
copy {clients/python => airflow-ctl}/LICENSE (100%)
create mode 100644 airflow-ctl/NOTICE
create mode 100644 chart/newsfragments/57615.misc.rst
copy LICENSE => go-sdk/LICENSE (100%)
create mode 100644 go-sdk/NOTICE
copy LICENSE => providers/airbyte/LICENSE (100%)
create mode 100644 providers/airbyte/NOTICE
copy LICENSE => providers/alibaba/LICENSE (100%)
create mode 100644 providers/alibaba/NOTICE
copy LICENSE => providers/amazon/LICENSE (100%)
create mode 100644 providers/amazon/NOTICE
copy LICENSE => providers/apache/beam/LICENSE (100%)
create mode 100644 providers/apache/beam/NOTICE
copy LICENSE => providers/apache/cassandra/LICENSE (100%)
create mode 100644 providers/apache/cassandra/NOTICE
copy LICENSE => providers/apache/drill/LICENSE (100%)
create mode 100644 providers/apache/drill/NOTICE
copy LICENSE => providers/apache/druid/LICENSE (100%)
create mode 100644 providers/apache/druid/NOTICE
copy LICENSE => providers/apache/flink/LICENSE (100%)
create mode 100644 providers/apache/flink/NOTICE
copy LICENSE => providers/apache/hdfs/LICENSE (100%)
create mode 100644 providers/apache/hdfs/NOTICE
copy LICENSE => providers/apache/hive/LICENSE (100%)
create mode 100644 providers/apache/hive/NOTICE
copy LICENSE => providers/apache/iceberg/LICENSE (100%)
create mode 100644 providers/apache/iceberg/NOTICE
copy LICENSE => providers/apache/impala/LICENSE (100%)
create mode 100644 providers/apache/impala/NOTICE
copy LICENSE => providers/apache/kafka/LICENSE (100%)
create mode 100644 providers/apache/kafka/NOTICE
copy LICENSE => providers/apache/kylin/LICENSE (100%)
create mode 100644 providers/apache/kylin/NOTICE
copy LICENSE => providers/apache/livy/LICENSE (100%)
create mode 100644 providers/apache/livy/NOTICE
copy LICENSE => providers/apache/pig/LICENSE (100%)
create mode 100644 providers/apache/pig/NOTICE
copy LICENSE => providers/apache/pinot/LICENSE (100%)
create mode 100644 providers/apache/pinot/NOTICE
copy LICENSE => providers/apache/spark/LICENSE (100%)
create mode 100644 providers/apache/spark/NOTICE
copy LICENSE => providers/apache/tinkerpop/LICENSE (100%)
create mode 100644 providers/apache/tinkerpop/NOTICE
copy LICENSE => providers/apprise/LICENSE (100%)
create mode 100644 providers/apprise/NOTICE
copy LICENSE => providers/arangodb/LICENSE (100%)
create mode 100644 providers/arangodb/NOTICE
copy LICENSE => providers/asana/LICENSE (100%)
create mode 100644 providers/asana/NOTICE
copy LICENSE => providers/atlassian/jira/LICENSE (100%)
create mode 100644 providers/atlassian/jira/NOTICE
copy LICENSE => providers/celery/LICENSE (100%)
create mode 100644 providers/celery/NOTICE
copy LICENSE => providers/cloudant/LICENSE (100%)
create mode 100644 providers/cloudant/NOTICE
copy LICENSE => providers/cncf/kubernetes/LICENSE (100%)
create mode 100644 providers/cncf/kubernetes/NOTICE
copy LICENSE => providers/cohere/LICENSE (100%)
create mode 100644 providers/cohere/NOTICE
copy LICENSE => providers/common/compat/LICENSE (100%)
create mode 100644 providers/common/compat/NOTICE
copy LICENSE => providers/common/io/LICENSE (100%)
create mode 100644 providers/common/io/NOTICE
copy LICENSE => providers/common/messaging/LICENSE (100%)
create mode 100644 providers/common/messaging/NOTICE
copy LICENSE => providers/common/sql/LICENSE (100%)
create mode 100644 providers/common/sql/NOTICE
copy LICENSE => providers/databricks/LICENSE (100%)
create mode 100644 providers/databricks/NOTICE
copy LICENSE => providers/datadog/LICENSE (100%)
create mode 100644 providers/datadog/NOTICE
copy LICENSE => providers/dbt/cloud/LICENSE (100%)
create mode 100644 providers/dbt/cloud/NOTICE
copy LICENSE => providers/dingding/LICENSE (100%)
create mode 100644 providers/dingding/NOTICE
copy LICENSE => providers/discord/LICENSE (100%)
create mode 100644 providers/discord/NOTICE
copy LICENSE => providers/docker/LICENSE (100%)
create mode 100644 providers/docker/NOTICE
copy LICENSE => providers/edge3/LICENSE (100%)
create mode 100644 providers/edge3/NOTICE
copy LICENSE => providers/elasticsearch/LICENSE (100%)
create mode 100644 providers/elasticsearch/NOTICE
copy LICENSE => providers/exasol/LICENSE (100%)
create mode 100644 providers/exasol/NOTICE
copy LICENSE => providers/fab/LICENSE (100%)
copy LICENSE => providers/facebook/LICENSE (100%)
create mode 100644 providers/facebook/NOTICE
copy LICENSE => providers/ftp/LICENSE (100%)
create mode 100644 providers/ftp/NOTICE
copy LICENSE => providers/git/LICENSE (100%)
create mode 100644 providers/git/NOTICE
copy LICENSE => providers/github/LICENSE (100%)
create mode 100644 providers/github/NOTICE
copy LICENSE => providers/google/LICENSE (100%)
create mode 100644 providers/google/NOTICE
copy LICENSE => providers/grpc/LICENSE (100%)
create mode 100644 providers/grpc/NOTICE
copy LICENSE => providers/hashicorp/LICENSE (100%)
create mode 100644 providers/hashicorp/NOTICE
copy LICENSE => providers/http/LICENSE (100%)
create mode 100644 providers/http/NOTICE
copy LICENSE => providers/imap/LICENSE (100%)
create mode 100644 providers/imap/NOTICE
copy LICENSE => providers/influxdb/LICENSE (100%)
create mode 100644 providers/influxdb/NOTICE
copy LICENSE => providers/jdbc/LICENSE (100%)
create mode 100644 providers/jdbc/NOTICE
copy LICENSE => providers/jenkins/LICENSE (100%)
create mode 100644 providers/jenkins/NOTICE
copy LICENSE => providers/keycloak/LICENSE (100%)
create mode 100644 providers/keycloak/NOTICE
copy LICENSE => providers/microsoft/azure/LICENSE (100%)
create mode 100644 providers/microsoft/azure/NOTICE
copy LICENSE => providers/microsoft/mssql/LICENSE (100%)
create mode 100644 providers/microsoft/mssql/NOTICE
copy LICENSE => providers/microsoft/psrp/LICENSE (100%)
create mode 100644 providers/microsoft/psrp/NOTICE
copy LICENSE => providers/microsoft/winrm/LICENSE (100%)
create mode 100644 providers/microsoft/winrm/NOTICE
copy LICENSE => providers/mongo/LICENSE (100%)
create mode 100644 providers/mongo/NOTICE
copy LICENSE => providers/mysql/LICENSE (100%)
create mode 100644 providers/mysql/NOTICE
copy LICENSE => providers/neo4j/LICENSE (100%)
create mode 100644 providers/neo4j/NOTICE
copy LICENSE => providers/odbc/LICENSE (100%)
create mode 100644 providers/odbc/NOTICE
copy LICENSE => providers/openai/LICENSE (100%)
create mode 100644 providers/openai/NOTICE
copy LICENSE => providers/openfaas/LICENSE (100%)
create mode 100644 providers/openfaas/NOTICE
copy LICENSE => providers/openlineage/LICENSE (100%)
create mode 100644 providers/openlineage/NOTICE
copy LICENSE => providers/opensearch/LICENSE (100%)
create mode 100644 providers/opensearch/NOTICE
copy LICENSE => providers/opsgenie/LICENSE (100%)
create mode 100644 providers/opsgenie/NOTICE
copy LICENSE => providers/oracle/LICENSE (100%)
create mode 100644 providers/oracle/NOTICE
copy LICENSE => providers/pagerduty/LICENSE (100%)
create mode 100644 providers/pagerduty/NOTICE
copy LICENSE => providers/papermill/LICENSE (100%)
create mode 100644 providers/papermill/NOTICE
copy LICENSE => providers/pgvector/LICENSE (100%)
create mode 100644 providers/pgvector/NOTICE
copy LICENSE => providers/pinecone/LICENSE (100%)
create mode 100644 providers/pinecone/NOTICE
copy LICENSE => providers/postgres/LICENSE (100%)
create mode 100644 providers/postgres/NOTICE
copy LICENSE => providers/presto/LICENSE (100%)
create mode 100644 providers/presto/NOTICE
copy LICENSE => providers/qdrant/LICENSE (100%)
create mode 100644 providers/qdrant/NOTICE
copy LICENSE => providers/redis/LICENSE (100%)
create mode 100644 providers/redis/NOTICE
copy LICENSE => providers/salesforce/LICENSE (100%)
create mode 100644 providers/salesforce/NOTICE
copy LICENSE => providers/samba/LICENSE (100%)
create mode 100644 providers/samba/NOTICE
copy LICENSE => providers/segment/LICENSE (100%)
create mode 100644 providers/segment/NOTICE
copy LICENSE => providers/sendgrid/LICENSE (100%)
create mode 100644 providers/sendgrid/NOTICE
copy LICENSE => providers/sftp/LICENSE (100%)
create mode 100644 providers/sftp/NOTICE
copy LICENSE => providers/singularity/LICENSE (100%)
create mode 100644 providers/singularity/NOTICE
copy LICENSE => providers/slack/LICENSE (100%)
create mode 100644 providers/slack/NOTICE
copy LICENSE => providers/smtp/LICENSE (100%)
create mode 100644 providers/smtp/NOTICE
copy LICENSE => providers/snowflake/LICENSE (100%)
create mode 100644 providers/snowflake/NOTICE
copy LICENSE => providers/sqlite/LICENSE (100%)
create mode 100644 providers/sqlite/NOTICE
copy LICENSE => providers/ssh/LICENSE (100%)
create mode 100644 providers/ssh/NOTICE
copy LICENSE => providers/standard/LICENSE (100%)
create mode 100644 providers/standard/NOTICE
copy LICENSE => providers/tableau/LICENSE (100%)
create mode 100644 providers/tableau/NOTICE
copy LICENSE => providers/telegram/LICENSE (100%)
create mode 100644 providers/telegram/NOTICE
copy LICENSE => providers/teradata/LICENSE (100%)
create mode 100644 providers/teradata/NOTICE
copy LICENSE => providers/trino/LICENSE (100%)
create mode 100644 providers/trino/NOTICE
copy LICENSE => providers/vertica/LICENSE (100%)
create mode 100644 providers/vertica/NOTICE
copy LICENSE => providers/weaviate/LICENSE (100%)
create mode 100644 providers/weaviate/NOTICE
copy LICENSE => providers/yandex/LICENSE (100%)
create mode 100644 providers/yandex/NOTICE
copy LICENSE => providers/ydb/LICENSE (100%)
create mode 100644 providers/ydb/NOTICE
copy LICENSE => providers/zendesk/LICENSE (100%)
create mode 100644 providers/zendesk/NOTICE
copy providers/google/tests/unit/google/cloud/utils/test_dataform.py =>
task-sdk-tests/dags/test_asset_dag.py (56%)
create mode 100644
task-sdk-tests/tests/task_sdk_tests/test_asset_event_operations.py
create mode 100644 task-sdk-tests/tests/task_sdk_tests/test_asset_operations.py
create mode 100644
task-sdk-tests/tests/task_sdk_tests/test_dag_run_operations.py
create mode 100644 task-sdk/NOTICE
