This is an automated email from the ASF dual-hosted git repository.
weilee pushed a change to branch render-json-logs-new-ui
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 1495cfd5f0c test(log_handlers): fix pendulum.tz version imcompat
omit a91cbb476ed test: ignore unneeded tests
omit bc6fd582dde feat(providers/opensearch): add airflow 3 task handler log
handling logic
omit 144f5f2c09c feat(providers/redis): add airflow 3 task handler log
handling logic
omit 5707bd6309a feat(providers/microsoft): add airflow 3 task handler log
handling logic
omit 4290f5d3de5 feat(providers/elasticsearch): add airflow 3 task handler
log handling logic
omit 9608e40f7b1 feat(providers/google): add airflow 3 task handler log
handling logic
omit b648ce470b7 feat(providers/amazon): add airflow 3 compat logic
omit 7a9e861b88f test(providers/amazon): fix
TestCloudwatchTaskHandler::test_read
omit 4aa4a32f7e4 test(providers/elasticsearch): fix part of the existing
unit test
omit 3d31c8f8fcb feat(api_connexion/log): update v1 api to the latest log
format
omit a9933a36869 test(api_fastapi): fix existing test_log unit tests
omit 5c3c9f88c4a test(www): fix existing unit tests
omit 26ff467c13e test(test_log_reader): fix existing unit tests
omit 37a7ab659c7 style: improve type annotation
omit d6b83810191 style: reduce if-else and directly use bool for assigning
metadata["download_logs"]
omit 3df890dfe79 style: group metadata pop
omit 3b3a643c6c2 Fix typescript useLogs
omit e222ffd0e08 Render structured logs in the new UI rather than showing
raw JSON
add bbdb45dcb9c Better handle timeouts on test failures (#46993)
add 122496487ae Add the delete pool button (#46995)
add a2158805636 Fix `exists` method to support using Requester Pays
(#46759)
add 5acc34de695 Fix backfill behavior for existing dag runs (#46959)
add a369c6da152 fix: Update broken AWS logo image path in README to
correct location and use raw URL (#47001)
add a5bb34fa560 Add edit pool button (#46998)
add a17decffcd2 Make run_after optional as part of API (#46967)
add c6bf166b703 Restricting moto 5.1.0 to fix ci (#47005)
add 3ce47aa4f70 AIP-84 Adding logging actions (#46814)
add 8d6169430da Fix TestRdsCopyDbSnapshotOperator tests (#47006)
add 961e33d32e5 AIP-72: Port over executor_config for K8sExecutor when
using task sdk (#46926)
add dbf8bb40922 Remove extra whitespace in provider readme template
(#46975)
add 94145446d1a Update documentation for Dataflow operators (#46954)
add 4f0a6670587 Fix Backfill CLI command with dry run (#46920)
add 518287ce7fb Runtime context shouldn't have start_date as a key (#46961)
add a10eec9c250 Update documentation on how to setup loca venv and PyCharm
IDE (#47017)
add 93148e1676f Better diagnostics for timeout case (#47021)
add 06db8ceb081 Execution API server types should not have `type`
attributes, only supervisor comms (#47022)
add ed80816316b Fix schema alias handling in ConnectionResult (#46957)
add f0bf5a1beb9 spark on kubernetes removes dependency on Spark Exit code
(#46817)
add 8d0895b8b8a spark on kubernetes removes dependency on Spark Exit code
(#46817)
add 7700687c37e Add Trino Connection UI Fields Placeholders (#46996)
add e810f00d2d7 Fix HttpSensor to enable returning xcom value (#46848)
add af4cc3d3f4f [Docs] Fix typo in
contributing-docs/quick-start-ide/contributors_quick_start_codespaces.rst
(#46899)
add 137042831a8 Add MwaaDagRunSensor to Amazon Provider Package (#46945)
add 8d3c8bf3589 Return 400 for dag_run_id with include_past/include_future
in clearTaskInstances API (#47036)
add 6f83dda4703 More import aliases in airflow.sdk (#46889)
add be464b48d6b Bump number of PRs the PROTM script considers (#47044)
add 42406162cac AIP-38 Fix MapIndex table sorting (#47027)
add 99c9e48aed6 Pool name shouldn't be updated via pool PATCH API call
(#46986)
add 5946e60f439 AIP-84 Fix sqlite test lock error on logs (#47016)
add adf36ff78b8 Web stack injectable path documentation (#46974)
add 1abd63731ae Remove example_dags folder (#47052)
add 811fa2b016c Replace `external_trigger` check with DagRunType (#45961)
add 2589cedbfd0 Update count of example dags after #47052 removed some
(#47058)
add bb6be350c0f Auto-generate the Pydantic datamodels for TaskSDK in
pre-commit (#47026)
add 8379804182a AIP-65 | Add dag versions to DAGRunResponse (#46484)
add 05079fd7f02 Don't run the webserver anymore on Airflow3 with `breeze
start-airflow`. (#47060)
add c34b73a46eb Remove `/webapp` prefix from new UI (#47041)
add 1648d7ef61f update xcom docs (#46284)
add 4fd812a6def Undo changes to accordion done in #46348 (#47054)
add 60b2220c171 Introduce DeltaTriggerTimetable (#46846)
add ca6421789d5 Create AIP-82 documentation (#46912)
add aab624de4c9 AIP-84 Add latest dag version to dag details (#47066)
add 9a72bcb6cfb Remove stray docstring (#47075)
add 82e14d540de Removing stripping quotes on XComOperatorLink (#47045)
add 2c13c18572c Limiting sqlalchemy-drill 1.1.6 as it breaks CI (#47079)
add febde142eb3 AIP-38 Fix dialog note state (#47071)
add 4e0aa267507 Remove link to the legacy UI (#47078)
add c03e6ec3b3e Rearrange Dag details view (#46939)
add c6c4f95ed9e Add legacy namespace packages to airflow.providers (#47064)
add fbbe59a2a92 Correctly support resuming tasks after triggers (#47061)
add 9276ae47487 Bump openlineage-airflow from 1.28.0 to 1.29.0 (#47067)
add 3703b4b577f [Docs] Fix typos and improve clarity in Gitpod setup guide
(#47057)
add 9bca9636fbe Update check-health.rst (#47077)
add 6332afc5dc0 Move `fastapi-api` command to `api-server` (#47076)
add ed34219d1b7 Fix breeze api-server - missed it during config move
(#47086)
add 4002d83243e AIP-72: Add support for getting connections from BaseHook
using task sdk (#47048)
add 17adf3af592 Get Boring Cyborg a commit (#47038)
add b966391133a Disable data interval by default (#47070)
add d7e1068f6a6 Render structured logs in the new UI rather than showing
raw JSON
add 09ca46094d8 Fix typescript useLogs
add 3003e057118 style: group metadata pop
add 31c4590c2bd style: reduce if-else and directly use bool for assigning
metadata["download_logs"]
add 83f0597f1d7 style: improve type annotation
add 0f15c8e464c test(test_log_reader): fix existing unit tests
add b000815a451 test(www): fix existing unit tests
add c29f0e4131b test(api_fastapi): fix existing test_log unit tests
add eb8be052fef feat(api_connexion/log): update v1 api to the latest log
format
add 40ee8b05fb9 test(providers/elasticsearch): fix part of the existing
unit test
add 6c9f8641396 test(providers/amazon): fix
TestCloudwatchTaskHandler::test_read
add 6612a1b67c2 feat(providers/amazon): add airflow 3 compat logic
add 82fc09feec1 feat(providers/google): add airflow 3 task handler log
handling logic
add 7fa3edcb2df feat(providers/elasticsearch): add airflow 3 task handler
log handling logic
add 70c72a04ce3 feat(providers/microsoft): add airflow 3 task handler log
handling logic
add 810a2c342b3 feat(providers/redis): add airflow 3 task handler log
handling logic
add f63faf8636a feat(providers/opensearch): add airflow 3 task handler log
handling logic
add 31aaf920a53 test: ignore unneeded tests
add 074f7b71bc6 test(log_handlers): fix pendulum.tz version imcompat
add ba1049e0e65 feat: force StructuredLogMessage check when initialing
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 (1495cfd5f0c)
\
N -- N -- N refs/heads/render-json-logs-new-ui (ba1049e0e65)
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:
.pre-commit-config.yaml | 9 +
README.md | 2 +-
airflow/api/client/local_client.py | 1 -
airflow/api/common/mark_tasks.py | 2 +-
airflow/api/common/trigger_dag.py | 4 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 2 -
airflow/api_connexion/schemas/dag_run_schema.py | 1 -
airflow/api_fastapi/app.py | 16 +-
airflow/api_fastapi/core_api/app.py | 6 +-
airflow/api_fastapi/core_api/datamodels/dag_run.py | 11 +-
airflow/api_fastapi/core_api/datamodels/dags.py | 12 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 23 +-
.../api_fastapi/core_api/routes/public/assets.py | 5 +-
.../core_api/routes/public/backfills.py | 3 +
.../core_api/routes/public/connections.py | 7 +-
.../core_api/routes/public/dag_parsing.py | 4 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 3 -
.../api_fastapi/core_api/routes/public/pools.py | 6 +-
.../core_api/routes/public/task_instances.py | 10 +-
airflow/api_fastapi/execution_api/app.py | 8 +
.../execution_api/datamodels/taskinstance.py | 35 +-
.../execution_api/routes/task_instances.py | 54 +-
airflow/api_fastapi/gunicorn_config.py | 2 +-
.../auth/managers/simple/ui/src/login/Login.tsx | 2 +-
airflow/cli/cli_config.py | 52 +-
...astapi_api_command.py => api_server_command.py} | 10 +-
.../commands/local_commands/standalone_command.py | 8 +-
.../commands/remote_commands/backfill_command.py | 14 +-
.../cli/commands/remote_commands/task_command.py | 1 -
airflow/config_templates/config.yml | 44 +-
airflow/config_templates/unit_tests.cfg | 3 +
airflow/dag_processing/collection.py | 2 +-
airflow/dag_processing/processor.py | 2 +-
.../example_dags/example_kubernetes_executor.py | 19 +-
airflow/example_dags/example_params_trigger_ui.py | 6 +-
airflow/example_dags/example_params_ui_tutorial.py | 4 +-
airflow/example_dags/plugins/event_listener.py | 4 +-
airflow/exceptions.py | 1 -
airflow/executors/workloads.py | 1 +
airflow/hooks/base.py | 13 +
airflow/jobs/scheduler_job_runner.py | 4 +-
...=> 0059_3_0_0_remove_external_trigger_field.py} | 34 +-
airflow/models/backfill.py | 129 +-
airflow/models/baseoperator.py | 45 +-
airflow/models/baseoperatorlink.py | 3 +-
airflow/models/dag.py | 22 +-
airflow/models/dagrun.py | 24 +-
airflow/models/taskinstance.py | 1 -
airflow/timetables/_delta.py | 56 +
airflow/timetables/interval.py | 30 +-
airflow/timetables/trigger.py | 158 +-
airflow/ui/.env.example | 1 -
airflow/ui/index.html | 2 +-
airflow/ui/openapi-gen/requests/schemas.gen.ts | 37 +-
airflow/ui/openapi-gen/requests/types.gen.ts | 8 +-
airflow/ui/package.json | 3 +-
airflow/ui/pnpm-lock.yaml | 1257 ++++++-----
.../components/ActionAccordion/ActionAccordion.tsx | 73 +-
.../ui/src/components/ActionAccordion/columns.tsx | 2 +-
.../ui/src/components/Clear/Run/ClearRunButton.tsx | 2 +-
.../Clear/TaskInstance/ClearTaskInstanceButton.tsx | 4 +-
airflow/ui/src/components/Clear/columns.tsx | 2 +-
airflow/ui/src/components/HeaderCard.tsx | 81 +
.../src/components/MarkAs/Run/MarkRunAsButton.tsx | 2 +-
.../TaskInstance/MarkTaskInstanceAsButton.tsx | 4 +-
airflow/ui/src/components/Stat.tsx | 12 +-
.../TruncatedText.tsx} | 18 +-
airflow/ui/src/layouts/BaseLayout.tsx | 6 +-
airflow/ui/src/layouts/Details/DagBreadcrumb.tsx | 143 ++
airflow/ui/src/layouts/Details/DagVizModal.tsx | 105 -
airflow/ui/src/layouts/Details/DetailsLayout.tsx | 149 +-
airflow/ui/src/layouts/Details/Graph/Graph.tsx | 68 +-
airflow/ui/src/layouts/Details/Graph/TaskNode.tsx | 2 +-
airflow/ui/src/layouts/Details/Grid/Bar.tsx | 3 +-
airflow/ui/src/layouts/Details/Grid/Grid.tsx | 6 +-
airflow/ui/src/layouts/Details/Grid/GridButton.tsx | 6 +-
airflow/ui/src/layouts/Details/Grid/GridTI.tsx | 52 +-
airflow/ui/src/layouts/Details/Grid/TaskNames.tsx | 1 +
airflow/ui/src/layouts/Details/NavTabs.tsx | 72 +-
airflow/ui/src/layouts/Nav/Nav.tsx | 7 +-
airflow/ui/src/pages/Dag/Dag.tsx | 35 +-
airflow/ui/src/pages/Dag/Header.tsx | 152 +-
.../DeletePoolButton.tsx} | 22 +-
.../EditPoolButton.tsx} | 38 +-
airflow/ui/src/pages/Pools/PoolBar.tsx | 21 +-
airflow/ui/src/pages/Pools/PoolForm.tsx | 2 +-
airflow/ui/src/pages/Run/Details.tsx | 10 +-
airflow/ui/src/pages/Run/Header.tsx | 67 +-
airflow/ui/src/pages/Run/Run.tsx | 42 +-
airflow/ui/src/pages/Task/Header.tsx | 40 +-
airflow/ui/src/pages/Task/Task.tsx | 44 +-
airflow/ui/src/pages/TaskInstance/Header.tsx | 95 +-
airflow/ui/src/pages/TaskInstance/TaskInstance.tsx | 66 +-
airflow/ui/src/pages/TaskInstances.tsx | 8 +-
airflow/ui/src/queries/useClearRun.ts | 2 +
airflow/ui/src/queries/useClearTaskInstances.ts | 2 +
.../{useDeleteVariable.ts => useDeletePool.ts} | 16 +-
.../queries/{useEditVariable.ts => useEditPool.ts} | 38 +-
airflow/ui/src/queries/usePatchDagRun.ts | 2 +
airflow/ui/src/queries/usePatchTaskInstance.ts | 2 +
airflow/ui/src/queries/useTrigger.ts | 2 +
airflow/ui/src/router.tsx | 5 +-
airflow/ui/src/utils/index.ts | 1 +
.../src/utils/useContainerWidth.ts} | 35 +-
airflow/ui/src/vite-env.d.ts | 4 -
airflow/utils/db.py | 2 +-
airflow/utils/db_cleanup.py | 7 +-
airflow/utils/log/file_task_handler.py | 12 +-
airflow/www/utils.py | 1 -
airflow/www/views.py | 4 -
chart/values.schema.json | 2 +-
chart/values.yaml | 2 +-
contributing-docs/07_local_virtualenv.rst | 141 +-
contributing-docs/08_static_code_checks.rst | 2 +
.../contributors_quick_start_codespaces.rst | 4 +-
.../contributors_quick_start_gitpod.rst | 2 +-
.../contributors_quick_start_pycharm.rst | 22 +-
.../pycharm_add_provider_sources_and_tests.png | Bin 0 -> 694947 bytes
.../images/pycharm_add_task_sdk_sources.png | Bin 0 -> 412386 bytes
.../pycharm_adding_source_root_directories.png | Bin 187571 -> 0 bytes
dev/breeze/doc/03_developer_tasks.rst | 31 +-
dev/breeze/doc/images/output_static-checks.svg | 34 +-
dev/breeze/doc/images/output_static-checks.txt | 2 +-
.../airflow_breeze/commands/testing_commands.py | 119 +-
dev/breeze/src/airflow_breeze/global_constants.py | 2 +-
.../src/airflow_breeze/params/shell_params.py | 6 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 1 +
.../templates/PROVIDER_README_TEMPLATE.rst.jinja2 | 43 +-
dev/breeze/src/airflow_breeze/utils/visuals.py | 6 +-
dev/datamodel_code_formatter.py | 66 +
dev/perf/scheduler_dag_execution_timing.py | 1 -
dev/stats/get_important_pr_candidates.py | 2 +-
.../administration-and-deployment/index.rst | 1 +
.../logging-monitoring/check-health.rst | 2 +-
.../web-stack.rst} | 21 +-
.../authoring-and-scheduling/event-scheduling.rst | 109 +
.../authoring-and-scheduling/index.rst | 1 +
.../authoring-and-scheduling/timetable.rst | 104 +-
docs/apache-airflow/core-concepts/xcoms.rst | 23 +-
.../howto/docker-compose/docker-compose.yaml | 2 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 2296 ++++++++++----------
docs/apache-airflow/migrations-ref.rst | 4 +-
docs/conf.py | 8 +
generated/provider_dependencies.json | 2 +-
helm_tests/airflow_core/test_api_server.py | 2 +-
kubernetes_tests/test_kubernetes_executor.py | 15 -
newsfragments/45961.significant.rst | 22 +
newsfragments/47070.significant.rst | 25 +
performance/requirements.txt | 2 +-
providers/airbyte/README.rst | 43 +-
.../{tests/system => src/airflow}/__init__.py | 0
.../system => src/airflow/providers}/__init__.py | 0
providers/alibaba/README.rst | 43 +-
.../system => alibaba/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/amazon/README.rst | 43 +-
providers/amazon/docs/operators/mwaa.rst | 30 +-
providers/amazon/provider.yaml | 3 +
.../system => amazon/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../amazon/aws/auth_manager/aws_auth_manager.py | 6 +-
.../amazon/aws/auth_manager/router/login.py | 5 +-
.../airflow/providers/amazon/aws/sensors/mwaa.py | 113 +
.../airflow/providers/amazon/get_provider_info.py | 4 +
.../amazon/tests/system/amazon/aws/example_mwaa.py | 13 +-
.../amazon/aws/tests/test_aws_auth_manager.py | 2 +-
.../amazon/aws/auth_manager/router/test_login.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_mwaa.py | 1 -
.../tests/unit/amazon/aws/operators/test_rds.py | 16 +
.../tests/unit/amazon/aws/sensors/test_mwaa.py | 75 +
providers/apache/beam/README.rst | 43 +-
.../system => apache/beam/src/airflow}/__init__.py | 0
.../beam/src/airflow/providers}/__init__.py | 0
.../beam/src/airflow/providers/apache}/__init__.py | 0
providers/apache/cassandra/README.rst | 43 +-
.../cassandra/src/airflow}/__init__.py | 0
.../cassandra/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
.../providers/apache/cassandra/hooks/cassandra.py | 5 +-
providers/apache/drill/README.rst | 43 +-
providers/apache/drill/pyproject.toml | 2 +-
.../drill/src/airflow}/__init__.py | 0
.../drill/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
.../providers/apache/drill/get_provider_info.py | 2 +-
providers/apache/druid/README.rst | 43 +-
.../druid/src/airflow}/__init__.py | 0
.../druid/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/flink/README.rst | 43 +-
.../flink/src/airflow}/__init__.py | 0
.../flink/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/hdfs/README.rst | 43 +-
.../system => apache/hdfs/src/airflow}/__init__.py | 0
.../hdfs/src/airflow/providers}/__init__.py | 0
.../hdfs/src/airflow/providers/apache}/__init__.py | 0
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 2 +-
.../providers/apache/hdfs/sensors/web_hdfs.py | 3 +-
providers/apache/hive/README.rst | 43 +-
.../system => apache/hive/src/airflow}/__init__.py | 0
.../hive/src/airflow/providers}/__init__.py | 0
.../hive/src/airflow/providers/apache}/__init__.py | 0
providers/apache/iceberg/README.rst | 43 +-
.../iceberg/src/airflow}/__init__.py | 0
.../iceberg/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/impala/README.rst | 43 +-
.../impala/src/airflow}/__init__.py | 0
.../impala/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
.../providers/apache/impala/hooks/impala.py | 3 +-
providers/apache/kafka/README.rst | 43 +-
.../kafka/src/airflow}/__init__.py | 0
.../kafka/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/kylin/README.rst | 43 +-
.../kylin/src/airflow}/__init__.py | 0
.../kylin/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/livy/README.rst | 43 +-
.../system => apache/livy/src/airflow}/__init__.py | 0
.../livy/src/airflow/providers}/__init__.py | 0
.../livy/src/airflow/providers/apache}/__init__.py | 0
providers/apache/pig/README.rst | 43 +-
.../system => apache/pig/src/airflow}/__init__.py | 0
.../pig/src/airflow/providers}/__init__.py | 0
.../pig/src/airflow/providers/apache}/__init__.py | 0
providers/apache/pinot/README.rst | 43 +-
.../pinot/src/airflow}/__init__.py | 0
.../pinot/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
providers/apache/spark/README.rst | 43 +-
.../spark/src/airflow}/__init__.py | 0
.../spark/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apache}/__init__.py | 0
.../providers/apache/spark/hooks/spark_submit.py | 10 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 24 +
providers/apprise/README.rst | 43 +-
.../system => apprise/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/apprise/hooks/apprise.py | 3 +-
.../providers/apprise/notifications/apprise.py | 3 +-
providers/arangodb/README.rst | 43 +-
.../system => arangodb/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/asana/README.rst | 43 +-
.../tests/system => asana/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/asana/hooks/asana.py | 3 +-
providers/atlassian/jira/README.rst | 43 +-
.../jira/src/airflow}/__init__.py | 0
.../jira/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/atlassian}/__init__.py | 0
providers/celery/README.rst | 43 +-
.../system => celery/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/celery/cli/celery_command.py | 6 +-
.../providers/celery/executors/celery_executor.py | 2 +-
.../celery/executors/celery_executor_utils.py | 11 +-
.../providers/celery/sensors/celery_queue.py | 3 +-
providers/cloudant/README.rst | 43 +-
.../system => cloudant/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/cncf/kubernetes/README.rst | 43 +-
.../kubernetes/src/airflow}/__init__.py | 0
.../kubernetes/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/cncf}/__init__.py | 0
.../backcompat/backwards_compat_converters.py | 3 +-
.../airflow/providers/cncf/kubernetes/callbacks.py | 3 +-
.../cncf/kubernetes/cli/kubernetes_command.py | 7 +-
.../cncf/kubernetes/decorators/kubernetes.py | 2 +-
.../kubernetes/executors/kubernetes_executor.py | 19 +-
.../executors/kubernetes_executor_utils.py | 11 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 6 +-
.../cncf/kubernetes/kubernetes_helper_functions.py | 2 +-
.../kubernetes/operators/custom_object_launcher.py | 4 +-
.../providers/cncf/kubernetes/operators/job.py | 7 +-
.../providers/cncf/kubernetes/operators/kueue.py | 3 +-
.../providers/cncf/kubernetes/operators/pod.py | 8 +-
.../cncf/kubernetes/operators/resource.py | 2 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 3 +-
.../providers/cncf/kubernetes/pod_generator.py | 4 +-
.../kubernetes/resource_convert/env_variable.py | 3 +-
.../airflow/providers/cncf/kubernetes/secret.py | 3 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 3 +-
.../cncf/kubernetes/template_rendering.py | 2 +-
.../cncf/kubernetes/utils/k8s_resource_iterator.py | 3 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 9 +-
providers/cohere/README.rst | 43 +-
.../system => cohere/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/cohere/hooks/cohere.py | 3 +-
providers/common/compat/README.rst | 43 +-
.../compat/src/airflow}/__init__.py | 0
.../compat/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/common}/__init__.py | 0
providers/common/io/README.rst | 43 +-
.../system => common/io/src/airflow}/__init__.py | 0
.../io/src/airflow/providers}/__init__.py | 0
.../io/src/airflow/providers/common}/__init__.py | 0
providers/common/sql/README.rst | 43 +-
.../system => common/sql/src/airflow}/__init__.py | 0
.../sql/src/airflow/providers}/__init__.py | 0
.../sql/src/airflow/providers/common}/__init__.py | 0
providers/databricks/README.rst | 43 +-
.../system => databricks/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/databricks/hooks/databricks_sql.py | 5 +-
.../databricks/operators/databricks_sql.py | 3 +-
.../databricks/sensors/databricks_partition.py | 3 +-
providers/datadog/README.rst | 43 +-
.../system => datadog/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/datadog/hooks/datadog.py | 3 +-
.../airflow/providers/datadog/sensors/datadog.py | 3 +-
providers/dbt/cloud/README.rst | 43 +-
.../system => dbt/cloud/src/airflow}/__init__.py | 0
.../cloud/src/airflow/providers}/__init__.py | 0
.../cloud/src/airflow/providers/dbt}/__init__.py | 0
providers/dingding/README.rst | 43 +-
.../system => dingding/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/discord/README.rst | 43 +-
.../system => discord/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/docker/README.rst | 43 +-
.../system => docker/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/docker/hooks/docker.py | 5 +-
.../airflow/providers/docker/operators/docker.py | 6 +-
.../providers/docker/operators/docker_swarm.py | 5 +-
providers/edge/README.rst | 43 +-
.../tests/system => edge/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/elasticsearch/README.rst | 43 +-
.../src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/elasticsearch/hooks/elasticsearch.py | 3 +-
.../providers/elasticsearch/log/es_task_handler.py | 17 +-
providers/exasol/README.rst | 43 +-
.../system => exasol/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/fab/README.rst | 43 +-
.../tests/system => fab/src/airflow}/__init__.py | 0
.../providers/3rd-party-licenses/LICENSES-ui.txt | 89 -
.../src/airflow/providers}/__init__.py | 0
.../providers/fab/auth_manager/fab_auth_manager.py | 6 +-
.../fab/src/airflow/providers/fab/www/views.py | 2 +-
.../fab/www/views/test_views_custom_user_views.py | 2 +-
providers/facebook/README.rst | 43 +-
.../system => facebook/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/ftp/README.rst | 43 +-
.../tests/system => ftp/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/github/README.rst | 43 +-
.../system => github/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/github/hooks/github.py | 3 +-
.../airflow/providers/github/operators/github.py | 3 +-
.../src/airflow/providers/github/sensors/github.py | 3 +-
providers/google/README.rst | 43 +-
providers/google/docs/operators/cloud/dataflow.rst | 8 +
.../system => google/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/google/ads/hooks/ads.py | 7 +-
.../_internal_client/secret_manager_client.py | 5 +-
.../google/cloud/example_dags/__init__.py | 16 -
.../cloud/example_dags/example_cloud_task.py | 54 -
.../providers/google/cloud/hooks/alloy_db.py | 5 +-
.../airflow/providers/google/cloud/hooks/automl.py | 9 +-
.../providers/google/cloud/hooks/bigquery.py | 41 +-
.../providers/google/cloud/hooks/bigquery_dts.py | 16 +-
.../providers/google/cloud/hooks/bigtable.py | 5 +-
.../providers/google/cloud/hooks/cloud_batch.py | 7 +-
.../providers/google/cloud/hooks/cloud_build.py | 9 +-
.../providers/google/cloud/hooks/cloud_composer.py | 7 +-
.../google/cloud/hooks/cloud_memorystore.py | 7 +-
.../providers/google/cloud/hooks/cloud_run.py | 7 +-
.../providers/google/cloud/hooks/cloud_sql.py | 2 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 17 +-
.../providers/google/cloud/hooks/compute.py | 6 +-
.../providers/google/cloud/hooks/datacatalog.py | 7 +-
.../providers/google/cloud/hooks/dataflow.py | 24 +-
.../providers/google/cloud/hooks/dataform.py | 5 +-
.../providers/google/cloud/hooks/datafusion.py | 4 +-
.../providers/google/cloud/hooks/dataplex.py | 18 +-
.../providers/google/cloud/hooks/dataproc.py | 9 +-
.../google/cloud/hooks/dataproc_metastore.py | 7 +-
.../airflow/providers/google/cloud/hooks/dlp.py | 7 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 31 +-
.../airflow/providers/google/cloud/hooks/kms.py | 5 +-
.../google/cloud/hooks/kubernetes_engine.py | 16 +-
.../providers/google/cloud/hooks/life_sciences.py | 2 +-
.../providers/google/cloud/hooks/managed_kafka.py | 5 +-
.../google/cloud/hooks/natural_language.py | 5 +-
.../providers/google/cloud/hooks/os_login.py | 5 +-
.../airflow/providers/google/cloud/hooks/pubsub.py | 12 +-
.../providers/google/cloud/hooks/secret_manager.py | 5 +-
.../providers/google/cloud/hooks/spanner.py | 4 +-
.../providers/google/cloud/hooks/speech_to_text.py | 5 +-
.../providers/google/cloud/hooks/stackdriver.py | 8 +-
.../airflow/providers/google/cloud/hooks/tasks.py | 7 +-
.../providers/google/cloud/hooks/text_to_speech.py | 5 +-
.../providers/google/cloud/hooks/translate.py | 10 +-
.../google/cloud/hooks/vertex_ai/auto_ml.py | 7 +-
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 7 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 9 +-
.../google/cloud/hooks/vertex_ai/dataset.py | 7 +-
.../cloud/hooks/vertex_ai/endpoint_service.py | 5 +-
.../google/cloud/hooks/vertex_ai/feature_store.py | 7 +-
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 7 +-
.../google/cloud/hooks/vertex_ai/model_service.py | 5 +-
.../google/cloud/hooks/vertex_ai/pipeline_job.py | 7 +-
.../cloud/hooks/vertex_ai/prediction_service.py | 5 +-
.../google/cloud/hooks/video_intelligence.py | 5 +-
.../airflow/providers/google/cloud/hooks/vision.py | 7 +-
.../providers/google/cloud/hooks/workflows.py | 5 +-
.../google/cloud/links/kubernetes_engine.py | 3 +-
.../providers/google/cloud/log/gcs_task_handler.py | 6 +-
.../google/cloud/log/stackdriver_task_handler.py | 14 +-
.../providers/google/cloud/openlineage/utils.py | 6 +-
.../providers/google/cloud/operators/alloy_db.py | 11 +-
.../providers/google/cloud/operators/automl.py | 20 +-
.../providers/google/cloud/operators/bigquery.py | 12 +-
.../google/cloud/operators/bigquery_dts.py | 18 +-
.../providers/google/cloud/operators/bigtable.py | 4 +-
.../providers/google/cloud/operators/cloud_base.py | 3 +-
.../google/cloud/operators/cloud_batch.py | 6 +-
.../google/cloud/operators/cloud_build.py | 8 +-
.../google/cloud/operators/cloud_composer.py | 12 +-
.../google/cloud/operators/cloud_memorystore.py | 10 +-
.../providers/google/cloud/operators/cloud_run.py | 8 +-
.../providers/google/cloud/operators/compute.py | 7 +-
.../google/cloud/operators/datacatalog.py | 20 +-
.../providers/google/cloud/operators/dataform.py | 8 +-
.../providers/google/cloud/operators/datafusion.py | 2 +-
.../providers/google/cloud/operators/dataplex.py | 38 +-
.../providers/google/cloud/operators/dataproc.py | 12 +-
.../google/cloud/operators/dataproc_metastore.py | 16 +-
.../providers/google/cloud/operators/dlp.py | 36 +-
.../providers/google/cloud/operators/gcs.py | 5 +-
.../google/cloud/operators/kubernetes_engine.py | 4 +-
.../google/cloud/operators/managed_kafka.py | 10 +-
.../google/cloud/operators/natural_language.py | 8 +-
.../providers/google/cloud/operators/pubsub.py | 18 +-
.../google/cloud/operators/speech_to_text.py | 8 +-
.../google/cloud/operators/stackdriver.py | 8 +-
.../providers/google/cloud/operators/tasks.py | 10 +-
.../google/cloud/operators/text_to_speech.py | 6 +-
.../providers/google/cloud/operators/translate.py | 8 +-
.../google/cloud/operators/translate_speech.py | 6 +-
.../google/cloud/operators/vertex_ai/auto_ml.py | 14 +-
.../operators/vertex_ai/batch_prediction_job.py | 10 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 14 +-
.../google/cloud/operators/vertex_ai/dataset.py | 10 +-
.../cloud/operators/vertex_ai/endpoint_service.py | 10 +-
.../vertex_ai/hyperparameter_tuning_job.py | 10 +-
.../cloud/operators/vertex_ai/model_service.py | 10 +-
.../cloud/operators/vertex_ai/pipeline_job.py | 10 +-
.../google/cloud/operators/video_intelligence.py | 8 +-
.../providers/google/cloud/operators/vision.py | 10 +-
.../providers/google/cloud/operators/workflows.py | 12 +-
.../google/cloud/secrets/secret_manager.py | 3 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 8 +-
.../providers/google/cloud/sensors/bigtable.py | 5 +-
.../google/cloud/sensors/cloud_composer.py | 2 +-
.../providers/google/cloud/sensors/dataplex.py | 10 +-
.../providers/google/cloud/sensors/dataproc.py | 5 +-
.../google/cloud/sensors/dataproc_metastore.py | 3 +-
.../airflow/providers/google/cloud/sensors/gcs.py | 6 +-
.../providers/google/cloud/sensors/pubsub.py | 5 +-
.../providers/google/cloud/sensors/workflows.py | 8 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 8 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 22 +-
.../google/cloud/triggers/bigquery_dts.py | 3 +-
.../providers/google/cloud/triggers/cloud_batch.py | 3 +-
.../providers/google/cloud/triggers/cloud_build.py | 3 +-
.../google/cloud/triggers/cloud_composer.py | 2 +-
.../triggers/cloud_storage_transfer_service.py | 5 +-
.../providers/google/cloud/triggers/dataflow.py | 5 +-
.../providers/google/cloud/triggers/dataplex.py | 3 +-
.../providers/google/cloud/triggers/dataproc.py | 5 +-
.../google/cloud/triggers/kubernetes_engine.py | 2 +-
.../providers/google/cloud/triggers/pubsub.py | 3 +-
.../providers/google/cloud/triggers/vertex_ai.py | 15 +-
.../google/cloud/utils/credentials_provider.py | 7 +-
.../google/cloud/utils/external_token_supplier.py | 1 -
.../google/common/auth_backend/google_openid.py | 8 +-
.../src/airflow/providers/google/common/consts.py | 3 +-
.../providers/google/common/hooks/base_google.py | 15 +-
.../marketing_platform/hooks/analytics_admin.py | 5 +-
.../google/marketing_platform/hooks/search_ads.py | 2 +-
.../operators/analytics_admin.py | 12 +-
.../tests/unit/google/cloud/hooks/test_gcs.py | 6 +-
providers/grpc/README.rst | 43 +-
.../tests/system => grpc/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../grpc/src/airflow/providers/grpc/hooks/grpc.py | 2 +-
providers/hashicorp/README.rst | 43 +-
.../system => hashicorp/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/http/README.rst | 43 +-
.../tests/system => http/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/http/sensors/http.py | 9 +-
.../http/tests/unit/http/sensors/test_http.py | 28 +
providers/imap/README.rst | 43 +-
.../tests/system => imap/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/influxdb/README.rst | 43 +-
.../system => influxdb/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/jdbc/README.rst | 43 +-
.../tests/system => jdbc/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/jenkins/README.rst | 43 +-
.../system => jenkins/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/jenkins/hooks/jenkins.py | 1 +
.../jenkins/operators/jenkins_job_trigger.py | 4 +-
providers/microsoft/azure/README.rst | 43 +-
.../azure/src/airflow}/__init__.py | 0
.../azure/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/microsoft}/__init__.py | 0
.../airflow/providers/microsoft/azure/fs/adls.py | 3 +-
.../airflow/providers/microsoft/azure/hooks/adx.py | 5 +-
.../airflow/providers/microsoft/azure/hooks/asb.py | 16 +-
.../providers/microsoft/azure/hooks/base_azure.py | 5 +-
.../providers/microsoft/azure/hooks/batch.py | 3 +-
.../microsoft/azure/hooks/container_instance.py | 7 +-
.../microsoft/azure/hooks/container_registry.py | 5 +-
.../microsoft/azure/hooks/container_volume.py | 5 +-
.../providers/microsoft/azure/hooks/cosmos.py | 9 +-
.../microsoft/azure/hooks/data_factory.py | 14 +-
.../providers/microsoft/azure/hooks/data_lake.py | 17 +-
.../providers/microsoft/azure/hooks/fileshare.py | 3 +-
.../providers/microsoft/azure/hooks/msgraph.py | 4 +-
.../providers/microsoft/azure/hooks/synapse.py | 9 +-
.../providers/microsoft/azure/hooks/wasb.py | 18 +-
.../microsoft/azure/log/wasb_task_handler.py | 3 +-
.../providers/microsoft/azure/operators/adx.py | 3 +-
.../providers/microsoft/azure/operators/asb.py | 3 +-
.../providers/microsoft/azure/operators/batch.py | 3 +-
.../azure/operators/container_instances.py | 14 +-
.../providers/microsoft/azure/operators/synapse.py | 3 +-
.../providers/microsoft/azure/secrets/key_vault.py | 7 +-
.../microsoft/azure/triggers/data_factory.py | 3 +-
.../src/airflow/providers/microsoft/azure/utils.py | 3 +-
providers/microsoft/mssql/README.rst | 43 +-
.../mssql/src/airflow}/__init__.py | 0
.../mssql/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/microsoft}/__init__.py | 0
providers/microsoft/psrp/README.rst | 43 +-
.../psrp/src/airflow}/__init__.py | 0
.../psrp/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/microsoft}/__init__.py | 0
providers/microsoft/winrm/README.rst | 43 +-
.../winrm/src/airflow}/__init__.py | 0
.../winrm/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/microsoft}/__init__.py | 0
.../providers/microsoft/winrm/hooks/winrm.py | 5 +-
providers/mongo/README.rst | 43 +-
.../tests/system => mongo/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/mysql/README.rst | 43 +-
.../tests/system => mysql/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/neo4j/README.rst | 43 +-
.../tests/system => neo4j/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/neo4j/hooks/neo4j.py | 3 +-
providers/odbc/README.rst | 43 +-
.../tests/system => odbc/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/openai/README.rst | 43 +-
.../system => openai/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/openfaas/README.rst | 43 +-
.../system => openfaas/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/openlineage/README.rst | 43 +-
.../system => openlineage/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/openlineage/extractors/base.py | 4 +-
.../providers/openlineage/extractors/bash.py | 3 +-
.../providers/openlineage/extractors/manager.py | 6 +-
.../providers/openlineage/extractors/python.py | 3 +-
.../openlineage/facets/AirflowDagRunFacet.json | 3 -
.../openlineage/facets/AirflowRunFacet.json | 3 -
.../providers/openlineage/plugins/adapter.py | 20 +-
.../providers/openlineage/plugins/facets.py | 1 -
.../providers/openlineage/plugins/listener.py | 4 +-
.../src/airflow/providers/openlineage/sqlparser.py | 8 +-
.../src/airflow/providers/openlineage/utils/sql.py | 3 +-
.../airflow/providers/openlineage/utils/utils.py | 8 +-
.../tests/unit/openlineage/plugins/test_adapter.py | 7 +-
.../tests/unit/openlineage/utils/test_utils.py | 2 -
providers/opensearch/README.rst | 43 +-
.../system => opensearch/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/opensearch/log/os_task_handler.py | 9 +-
providers/opsgenie/README.rst | 43 +-
.../system => opsgenie/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/oracle/README.rst | 43 +-
.../system => oracle/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/pagerduty/README.rst | 43 +-
.../system => pagerduty/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/papermill/README.rst | 43 +-
.../system => papermill/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/papermill/hooks/kernel.py | 6 +-
.../providers/papermill/operators/papermill.py | 2 +-
providers/pgvector/README.rst | 43 +-
.../system => pgvector/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/pgvector/operators/pgvector.py | 3 +-
providers/pinecone/README.rst | 43 +-
.../system => pinecone/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/pinecone/hooks/pinecone.py | 6 +-
providers/postgres/README.rst | 43 +-
.../system => postgres/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/presto/README.rst | 43 +-
.../system => presto/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/qdrant/README.rst | 43 +-
.../system => qdrant/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/redis/README.rst | 43 +-
.../tests/system => redis/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/redis/hooks/redis.py | 3 +-
.../providers/redis/log/redis_task_handler.py | 3 +-
providers/salesforce/README.rst | 43 +-
.../system => salesforce/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/samba/README.rst | 43 +-
.../tests/system => samba/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/segment/README.rst | 43 +-
.../system => segment/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/sendgrid/README.rst | 43 +-
.../system => sendgrid/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/sendgrid/utils/emailer.py | 5 +-
providers/sftp/README.rst | 43 +-
.../tests/system => sftp/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/singularity/README.rst | 43 +-
.../system => singularity/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/slack/README.rst | 43 +-
.../tests/system => slack/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/smtp/README.rst | 43 +-
.../tests/system => smtp/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/snowflake/README.rst | 43 +-
.../system => snowflake/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/snowflake/hooks/snowflake.py | 9 +-
providers/sqlite/README.rst | 43 +-
.../system => sqlite/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/ssh/README.rst | 43 +-
.../tests/system => ssh/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/standard/README.rst | 43 +-
.../system => standard/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../providers/standard/operators/latest_only.py | 7 +-
.../airflow/providers/standard/operators/python.py | 2 -
.../tests/unit/standard/operators/test_bash.py | 1 -
.../operators/test_latest_only_operator.py | 3 -
providers/tableau/README.rst | 43 +-
.../system => tableau/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/telegram/README.rst | 43 +-
.../system => telegram/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/telegram/hooks/telegram.py | 2 +-
providers/teradata/README.rst | 43 +-
.../system => teradata/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/trino/README.rst | 43 +-
.../tests/system => trino/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/trino/hooks/trino.py | 39 +-
providers/vertica/README.rst | 43 +-
.../system => vertica/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
providers/weaviate/README.rst | 43 +-
.../system => weaviate/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/weaviate/hooks/weaviate.py | 10 +-
.../providers/weaviate/operators/weaviate.py | 1 -
providers/yandex/README.rst | 43 +-
.../system => yandex/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../airflow/providers/yandex/secrets/lockbox.py | 4 +-
providers/ydb/README.rst | 43 +-
.../tests/system => ydb/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
.../ydb/src/airflow/providers/ydb/hooks/ydb.py | 2 +-
providers/zendesk/README.rst | 43 +-
.../system => zendesk/src/airflow}/__init__.py | 0
.../src/airflow/providers}/__init__.py | 0
pyproject.toml | 17 +-
scripts/ci/docker-compose/base-ports.yml | 2 +-
.../check_providers_subpackages_all_have_init.py | 56 +-
scripts/ci/pre_commit/common_precommit_utils.py | 11 +-
scripts/ci/pre_commit/mypy.py | 6 +-
scripts/in_container/bin/run_tmux | 28 +-
scripts/in_container/run_mypy.sh | 1 +
task_sdk/dev/generate_models.py | 99 +
task_sdk/pyproject.toml | 12 +-
task_sdk/src/airflow/sdk/__init__.py | 32 +-
task_sdk/src/airflow/sdk/api/client.py | 2 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 16 +-
.../airflow/sdk/definitions/_internal/templater.py | 11 +-
.../src/airflow/sdk/definitions/baseoperator.py | 73 +-
task_sdk/src/airflow/sdk/definitions/connection.py | 7 +
task_sdk/src/airflow/sdk/definitions/dag.py | 9 +-
task_sdk/src/airflow/sdk/execution_time/comms.py | 21 +-
.../src/airflow/sdk/execution_time/supervisor.py | 10 +-
.../src/airflow/sdk/execution_time/task_runner.py | 25 +-
task_sdk/src/airflow/sdk/types.py | 4 +-
task_sdk/tests/api/test_client.py | 23 +-
task_sdk/tests/dags/super_basic_deferred_run.py | 2 +-
task_sdk/tests/execution_time/test_supervisor.py | 19 +-
task_sdk/tests/execution_time/test_task_runner.py | 43 +-
.../api_connexion/endpoints/test_asset_endpoint.py | 1 -
.../endpoints/test_dag_run_endpoint.py | 26 -
.../endpoints/test_dag_stats_endpoint.py | 4 -
tests/api_connexion/schemas/test_dag_run_schema.py | 3 -
tests/api_fastapi/common/test_exceptions.py | 6 +-
tests/api_fastapi/conftest.py | 55 +-
.../core_api/routes/public/test_assets.py | 20 +-
.../core_api/routes/public/test_backfills.py | 141 +-
.../core_api/routes/public/test_connections.py | 17 +-
.../core_api/routes/public/test_dag_parsing.py | 12 +-
.../core_api/routes/public/test_dag_run.py | 134 +-
.../core_api/routes/public/test_dag_stats.py | 4 -
.../core_api/routes/public/test_dags.py | 12 +
.../core_api/routes/public/test_pools.py | 50 +-
.../core_api/routes/public/test_task_instances.py | 25 +
tests/api_fastapi/core_api/routes/ui/test_dags.py | 2 +
.../execution_api/routes/test_task_instances.py | 65 +-
tests/api_fastapi/test_app.py | 11 +
...i_api_command.py => test_api_server_command.py} | 28 +-
.../commands/remote_commands/test_asset_command.py | 9 +-
.../remote_commands/test_backfill_command.py | 32 +
.../commands/remote_commands/test_dag_command.py | 2 -
.../commands/remote_commands/test_task_command.py | 1 -
tests/core/test_core.py | 1 -
tests/dag_processing/test_processor.py | 32 +-
tests/jobs/test_scheduler_job.py | 6 +-
tests/models/test_backfill.py | 104 +-
tests/models/test_dag.py | 2 +-
tests/models/test_dagrun.py | 15 +-
tests/models/test_taskinstance.py | 1 -
tests/operators/test_trigger_dagrun.py | 13 +-
tests/serialization/test_dag_serialization.py | 4 +-
tests/serialization/test_serialized_objects.py | 1 -
tests/timetables/test_interval_timetable.py | 25 +-
tests/timetables/test_trigger_timetable.py | 249 ++-
tests/utils/log/test_log_reader.py | 8 +-
tests/utils/test_db_cleanup.py | 54 +-
tests/utils/test_log_handlers.py | 8 +-
tests/www/test_utils.py | 1 -
tests/www/views/test_views_grid.py | 2 -
tests_common/test_utils/api_fastapi.py | 68 +
tests_common/test_utils/www.py | 32 +-
781 files changed, 8415 insertions(+), 6582 deletions(-)
rename airflow/cli/commands/local_commands/{fastapi_api_command.py =>
api_server_command.py} (93%)
copy airflow/migrations/versions/{0037_3_0_0_add_backfill_to_dag_run_model.py
=> 0059_3_0_0_remove_external_trigger_field.py} (59%)
create mode 100644 airflow/timetables/_delta.py
create mode 100644 airflow/ui/src/components/HeaderCard.tsx
copy airflow/ui/src/{layouts/Details/Grid/DurationTick.tsx =>
components/TruncatedText.tsx} (75%)
create mode 100644 airflow/ui/src/layouts/Details/DagBreadcrumb.tsx
delete mode 100644 airflow/ui/src/layouts/Details/DagVizModal.tsx
copy airflow/ui/src/pages/{Variables/ManageVariable/DeleteVariableButton.tsx
=> Pools/DeletePoolButton.tsx} (80%)
copy airflow/ui/src/pages/{Variables/ManageVariable/EditVariableButton.tsx =>
Pools/EditPoolButton.tsx} (66%)
copy airflow/ui/src/queries/{useDeleteVariable.ts => useDeletePool.ts} (70%)
copy airflow/ui/src/queries/{useEditVariable.ts => useEditPool.ts} (60%)
copy airflow/{www/static/js/utils/useErrorToast.ts =>
ui/src/utils/useContainerWidth.ts} (59%)
create mode 100644
contributing-docs/quick-start-ide/images/pycharm_add_provider_sources_and_tests.png
create mode 100644
contributing-docs/quick-start-ide/images/pycharm_add_task_sdk_sources.png
delete mode 100644
contributing-docs/quick-start-ide/images/pycharm_adding_source_root_directories.png
create mode 100644 dev/datamodel_code_formatter.py
copy docs/apache-airflow/{tutorial/index.rst =>
administration-and-deployment/web-stack.rst} (57%)
create mode 100644
docs/apache-airflow/authoring-and-scheduling/event-scheduling.rst
create mode 100644 newsfragments/45961.significant.rst
create mode 100644 newsfragments/47070.significant.rst
copy providers/airbyte/{tests/system => src/airflow}/__init__.py (100%)
copy providers/airbyte/{tests/system => src/airflow/providers}/__init__.py
(100%)
copy providers/{airbyte/tests/system => alibaba/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
alibaba/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => amazon/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
amazon/src/airflow/providers}/__init__.py (100%)
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/sensors/mwaa.py
create mode 100644 providers/amazon/tests/unit/amazon/aws/sensors/test_mwaa.py
copy providers/{airbyte/tests/system => apache/beam/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/beam/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/beam/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/cassandra/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/cassandra/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/cassandra/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/drill/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/drill/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/drill/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/druid/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/druid/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/druid/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/flink/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/flink/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/flink/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/hdfs/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/hdfs/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/hdfs/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/hive/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/hive/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/hive/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/iceberg/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/iceberg/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/iceberg/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/impala/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/impala/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/impala/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/kafka/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/kafka/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/kafka/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/kylin/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/kylin/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/kylin/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/livy/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/livy/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/livy/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/pig/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/pig/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/pig/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/pinot/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/pinot/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/pinot/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apache/spark/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
apache/spark/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apache/spark/src/airflow/providers/apache}/__init__.py (100%)
copy providers/{airbyte/tests/system => apprise/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
apprise/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => arangodb/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
arangodb/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => asana/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
asana/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
atlassian/jira/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
atlassian/jira/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
atlassian/jira/src/airflow/providers/atlassian}/__init__.py (100%)
copy providers/{airbyte/tests/system => celery/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
celery/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => cloudant/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
cloudant/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
cncf/kubernetes/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
cncf/kubernetes/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
cncf/kubernetes/src/airflow/providers/cncf}/__init__.py (100%)
copy providers/{airbyte/tests/system => cohere/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
cohere/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => common/compat/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
common/compat/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
common/compat/src/airflow/providers/common}/__init__.py (100%)
copy providers/{airbyte/tests/system => common/io/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
common/io/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
common/io/src/airflow/providers/common}/__init__.py (100%)
copy providers/{airbyte/tests/system => common/sql/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
common/sql/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
common/sql/src/airflow/providers/common}/__init__.py (100%)
copy providers/{airbyte/tests/system => databricks/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
databricks/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => datadog/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
datadog/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => dbt/cloud/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
dbt/cloud/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
dbt/cloud/src/airflow/providers/dbt}/__init__.py (100%)
copy providers/{airbyte/tests/system => dingding/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
dingding/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => discord/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
discord/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => docker/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
docker/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => edge/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
edge/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => elasticsearch/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
elasticsearch/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => exasol/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
exasol/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => fab/src/airflow}/__init__.py (100%)
delete mode 100644
providers/fab/src/airflow/providers/3rd-party-licenses/LICENSES-ui.txt
copy providers/{airbyte/tests/system => fab/src/airflow/providers}/__init__.py
(100%)
copy providers/{airbyte/tests/system => facebook/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
facebook/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => ftp/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system => ftp/src/airflow/providers}/__init__.py
(100%)
copy providers/{airbyte/tests/system => github/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
github/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => google/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
google/src/airflow/providers}/__init__.py (100%)
delete mode 100644
providers/google/src/airflow/providers/google/cloud/example_dags/__init__.py
delete mode 100644
providers/google/src/airflow/providers/google/cloud/example_dags/example_cloud_task.py
copy providers/{airbyte/tests/system => grpc/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
grpc/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => hashicorp/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
hashicorp/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => http/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
http/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => imap/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
imap/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => influxdb/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
influxdb/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => jdbc/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
jdbc/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => jenkins/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
jenkins/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/azure/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/azure/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/azure/src/airflow/providers/microsoft}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/mssql/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/mssql/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/mssql/src/airflow/providers/microsoft}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/psrp/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/psrp/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/psrp/src/airflow/providers/microsoft}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/winrm/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/winrm/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
microsoft/winrm/src/airflow/providers/microsoft}/__init__.py (100%)
copy providers/{airbyte/tests/system => mongo/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
mongo/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => mysql/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
mysql/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => neo4j/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
neo4j/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => odbc/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
odbc/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => openai/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
openai/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => openfaas/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
openfaas/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => openlineage/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
openlineage/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => opensearch/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
opensearch/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => opsgenie/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
opsgenie/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => oracle/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
oracle/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => pagerduty/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
pagerduty/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => papermill/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
papermill/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => pgvector/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
pgvector/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => pinecone/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
pinecone/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => postgres/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
postgres/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => presto/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
presto/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => qdrant/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
qdrant/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => redis/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
redis/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => salesforce/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
salesforce/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => samba/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
samba/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => segment/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
segment/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => sendgrid/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
sendgrid/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => sftp/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
sftp/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => singularity/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
singularity/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => slack/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
slack/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => smtp/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
smtp/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => snowflake/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
snowflake/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => sqlite/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
sqlite/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => ssh/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system => ssh/src/airflow/providers}/__init__.py
(100%)
copy providers/{airbyte/tests/system => standard/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
standard/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => tableau/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
tableau/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => telegram/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
telegram/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => teradata/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
teradata/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => trino/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
trino/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => vertica/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
vertica/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => weaviate/src/airflow}/__init__.py
(100%)
copy providers/{airbyte/tests/system =>
weaviate/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => yandex/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
yandex/src/airflow/providers}/__init__.py (100%)
copy providers/{airbyte/tests/system => ydb/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system => ydb/src/airflow/providers}/__init__.py
(100%)
copy providers/{airbyte/tests/system => zendesk/src/airflow}/__init__.py (100%)
copy providers/{airbyte/tests/system =>
zendesk/src/airflow/providers}/__init__.py (100%)
create mode 100644 task_sdk/dev/generate_models.py
rename tests/cli/commands/local_commands/{test_fastapi_api_command.py =>
test_api_server_command.py} (84%)
create mode 100644 tests_common/test_utils/api_fastapi.py
