This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a change to branch
revert-44550-bugfix/revert-edge-datamodelling-for-pydantic
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 8936459a012 Revert "Revert Edge Datamodelling for Pydantic problems in
Py3.9 (#44550)"
add 9765a420aff Remove Provider Deprecations in SSH (#44544)
add f1f64998bd9 Remove Provider Deprecations in Docker (#44583)
add aac80984ddc Add support for a subdir in GitDagBundle (#44582)
add 5b898ad63cb Add mTLS support to WebHDFSHook (#44561)
add 5c739ccfebb Fix cloud_sql and example_composer system tests (#44560)
add a242ff6edb5 Fix tests badge in README.md (#44505)
add 8d6bde8246c Ensure check_query_exists returns a bool (#43978)
add d62e3ec13a2 Bump `ruff` to `0.8.1` (#44591)
add 3505f9ab8c9 Add 'airflow assets materialize' (#44558)
add a3a596906cb Add host_proxy_cmd parameter to SSHHook and SFTPHook
(#44565)
add 71fec4e661a [Providers/HTTP] Add adapter parameter to HttpHook to
allow custom requests adapters (#44302)
add edf3e337681 Revert "Add 'airflow assets materialize' (#44558)" (#44602)
add a537d9cff3b Add 'airflow assets materialize' (again) (#44603)
add c0ca2d72bb1 Add back `eval-type-backport` to entrypoint_ci.sh as
pydantic workaround (#44589)
add 40821bfd5c5 Fix SQLite condition for detecting pickled data (#44611)
add d059d4a84b5 AIP-72: Port task success overtime to the Supervisor
(#44590)
add 31ba41e0244 AIP-84 Refactor Filter Query Parameters (#43947)
add 6ed71fa9416 Add DAG bundles model (#44586)
add 2b7015e5ffe AIP-81 Move CLI Commands to directories according to
Hybrid, Local and Remote (#44538)
add 0a347c41f09 Advise using pre-commit-uv when installing pre-commit with
uv (#44622)
add 8ca061ddf5f Deferrable sensors can implement sensor timeout (#33718)
add 4ffa6afc721 Rename head to tracking ref (#44585)
add c48975eb77a Remove Provider Deprecations in Jenkins (#44630)
add 6f1351122df Remove Provider Deprecations in Apache Livy (#44631)
add 5c2253f002d Remove Provider Deprecations in Mongo (#44632)
add c72adf407df Fix a couple comments (#44623)
add 5c7fac61e37 Revert "Revert Edge Datamodelling for Pydantic problems in
Py3.9 (#44550)"
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 (8936459a012)
\
N -- N -- N
refs/heads/revert-44550-bugfix/revert-edge-datamodelling-for-pydantic
(5c7fac61e37)
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/boring-cyborg.yml | 12 +-
.pre-commit-config.yaml | 8 +-
Dockerfile.ci | 16 +
README.md | 2 +-
airflow/api/common/trigger_dag.py | 17 +-
airflow/api_fastapi/common/parameters.py | 597 +--
.../api_fastapi/core_api/openapi/v1-generated.yaml | 46 +-
.../api_fastapi/core_api/routes/public/assets.py | 27 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 8 +-
.../core_api/routes/public/dag_stats.py | 16 +-
.../core_api/routes/public/dag_warning.py | 13 +-
.../core_api/routes/public/event_logs.py | 77 +-
airflow/api_fastapi/core_api/routes/public/job.py | 26 +-
.../core_api/routes/public/task_instances.py | 23 +-
airflow/api_fastapi/gunicorn_config.py | 2 +-
airflow/cli/cli_config.py | 196 +-
.../commands/hybrid_commands}/__init__.py | 0
.../{ => hybrid_commands}/kubernetes_command.py | 0
.../commands/local_commands}/__init__.py | 0
.../{ => local_commands}/celery_command.py | 2 +-
.../{ => local_commands}/cheat_sheet_command.py | 0
.../commands/{ => local_commands}/daemon_utils.py | 0
.../{ => local_commands}/dag_processor_command.py | 2 +-
.../commands/{ => local_commands}/db_command.py | 0
.../{ => local_commands}/fastapi_api_command.py | 6 +-
.../commands/{ => local_commands}/info_command.py | 0
.../{ => local_commands}/kerberos_command.py | 2 +-
.../{ => local_commands}/plugins_command.py | 0
.../rotate_fernet_key_command.py | 0
.../{ => local_commands}/scheduler_command.py | 2 +-
.../{ => local_commands}/standalone_command.py | 0
.../{ => local_commands}/triggerer_command.py | 2 +-
.../{ => local_commands}/webserver_command.py | 2 +-
.../commands/remote_commands}/__init__.py | 0
.../{ => remote_commands}/asset_command.py | 42 +-
.../{ => remote_commands}/backfill_command.py | 0
.../{ => remote_commands}/config_command.py | 0
.../{ => remote_commands}/connection_command.py | 0
.../commands/{ => remote_commands}/dag_command.py | 0
.../commands/{ => remote_commands}/jobs_command.py | 0
.../commands/{ => remote_commands}/pool_command.py | 0
.../{ => remote_commands}/provider_command.py | 0
.../commands/{ => remote_commands}/task_command.py | 0
.../{ => remote_commands}/variable_command.py | 0
.../{ => remote_commands}/version_command.py | 0
airflow/dag_processing/bundles/git.py | 24 +-
airflow/dag_processing/processor.py | 4 +-
airflow/exceptions.py | 14 +-
airflow/jobs/scheduler_job_runner.py | 5 +-
...49_3_0_0_remove_pickled_data_from_xcom_table.py | 2 +-
.../versions/0050_3_0_0_add_dagbundlemodel.py | 68 +
airflow/models/__init__.py | 1 +
airflow/models/baseoperator.py | 11 +-
airflow/models/dag.py | 4 +
airflow/models/dagbundle.py | 73 +
airflow/models/taskinstance.py | 1 +
airflow/models/trigger.py | 29 +-
airflow/sensors/base.py | 5 +-
airflow/ui/openapi-gen/queries/prefetch.ts | 6 +-
airflow/ui/openapi-gen/queries/queries.ts | 6 +-
airflow/ui/openapi-gen/queries/suspense.ts | 6 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 12 +-
airflow/utils/db.py | 5 +-
airflow/www/gunicorn_config.py | 2 +-
dev/breeze/src/airflow_breeze/utils/run_utils.py | 6 +-
.../connections.rst | 2 +
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 4028 ++++++++++----------
docs/apache-airflow/migrations-ref.rst | 4 +-
docs/spelling_wordlist.txt | 2 +
generated/PYPI_README.md | 2 +-
hatch_build.py | 2 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 20 +
.../airflow/providers/apache/livy/CHANGELOG.rst | 11 +
.../providers/apache/livy/operators/livy.py | 9 +-
.../airflow/providers/celery/cli/celery_command.py | 2 +-
.../providers/celery/executors/celery_executor.py | 2 +-
.../src/airflow/providers/docker/CHANGELOG.rst | 17 +
.../airflow/providers/docker/decorators/docker.py | 20 +-
.../airflow/providers/docker/operators/docker.py | 34 -
.../fab/auth_manager/cli_commands/db_command.py | 2 +-
providers/src/airflow/providers/http/hooks/http.py | 126 +-
.../src/airflow/providers/jenkins/CHANGELOG.rst | 11 +
.../jenkins/operators/jenkins_job_trigger.py | 8 +-
.../src/airflow/providers/mongo/CHANGELOG.rst | 11 +
.../src/airflow/providers/mongo/hooks/mongo.py | 12 +-
providers/src/airflow/providers/sftp/hooks/sftp.py | 2 +
providers/src/airflow/providers/ssh/CHANGELOG.rst | 20 +
providers/src/airflow/providers/ssh/hooks/ssh.py | 76 +-
.../src/airflow/providers/ssh/operators/ssh.py | 20 +-
.../providers/standard/sensors/time_delta.py | 21 +-
providers/tests/apache/hdfs/hooks/test_webhdfs.py | 48 +
providers/tests/apache/livy/operators/test_livy.py | 8 +-
providers/tests/celery/cli/test_celery_command.py | 8 +-
providers/tests/docker/decorators/test_docker.py | 38 +-
providers/tests/docker/operators/test_docker.py | 116 +-
providers/tests/http/hooks/test_http.py | 16 +-
providers/tests/mongo/hooks/test_mongo.py | 23 +-
providers/tests/sftp/hooks/test_sftp.py | 28 +
providers/tests/ssh/hooks/test_ssh.py | 209 +-
.../cloud/cloud_sql/example_cloud_sql_query_iam.py | 3 +-
.../cloud/composer/example_cloud_composer.py | 2 +-
.../check_cncf_k8s_used_for_k8s_executor_only.py | 2 +-
scripts/cov/cli_coverage.py | 34 +-
scripts/docker/entrypoint_ci.sh | 16 +
.../in_container/run_provider_yaml_files_check.py | 2 +-
task_sdk/src/airflow/sdk/execution_time/comms.py | 2 +
.../src/airflow/sdk/execution_time/supervisor.py | 37 +-
.../src/airflow/sdk/execution_time/task_runner.py | 12 +-
task_sdk/tests/execution_time/test_supervisor.py | 69 +-
task_sdk/tests/execution_time/test_task_runner.py | 20 +-
.../api_fastapi/core_api/routes/public/test_job.py | 2 +-
.../cli/commands/hybrid_commands}/__init__.py | 0
.../test_kubernetes_command.py | 18 +-
.../cli/commands/local_commands}/__init__.py | 0
.../{ => local_commands}/test_celery_command.py | 32 +-
.../test_cheat_sheet_command.py | 0
.../test_dag_processor_command.py | 4 +-
.../{ => local_commands}/test_db_command.py | 79 +-
.../test_fastapi_api_command.py | 4 +-
.../{ => local_commands}/test_info_command.py | 4 +-
.../{ => local_commands}/test_kerberos_command.py | 18 +-
.../{ => local_commands}/test_plugins_command.py | 14 +-
.../test_rotate_fernet_key_command.py | 2 +-
.../{ => local_commands}/test_scheduler_command.py | 55 +-
.../test_standalone_command.py | 2 +-
.../{ => local_commands}/test_triggerer_command.py | 12 +-
.../{ => local_commands}/test_webserver_command.py | 22 +-
.../cli/commands/remote_commands}/__init__.py | 0
.../{ => remote_commands}/test_asset_command.py | 41 +-
.../{ => remote_commands}/test_backfill_command.py | 6 +-
.../{ => remote_commands}/test_config_command.py | 12 +-
.../test_connection_command.py | 4 +-
.../{ => remote_commands}/test_dag_command.py | 33 +-
.../{ => remote_commands}/test_jobs_command.py | 2 +-
.../{ => remote_commands}/test_pool_command.py | 2 +-
.../{ => remote_commands}/test_task_command.py | 43 +-
.../{ => remote_commands}/test_variable_command.py | 2 +-
.../{ => remote_commands}/test_version_command.py | 4 +-
tests/cli/commands/test_legacy_commands.py | 2 +-
tests/dag_processing/test_dag_bundles.py | 37 +-
tests/deprecations_ignore.yml | 2 +-
.../cli/commands/test_celery_command.py | 6 +-
tests/listeners/file_write_listener.py | 2 +-
tests/models/test_baseoperator.py | 12 +-
tests/sensors/test_base.py | 10 +
tests/utils/test_db.py | 16 +-
tests/utils/test_db_cleanup.py | 1 +
148 files changed, 3620 insertions(+), 3474 deletions(-)
copy airflow/{api_connexion => cli/commands/hybrid_commands}/__init__.py (100%)
rename airflow/cli/commands/{ => hybrid_commands}/kubernetes_command.py (100%)
copy airflow/{api_connexion => cli/commands/local_commands}/__init__.py (100%)
rename airflow/cli/commands/{ => local_commands}/celery_command.py (98%)
rename airflow/cli/commands/{ => local_commands}/cheat_sheet_command.py (100%)
rename airflow/cli/commands/{ => local_commands}/daemon_utils.py (100%)
rename airflow/cli/commands/{ => local_commands}/dag_processor_command.py (96%)
rename airflow/cli/commands/{ => local_commands}/db_command.py (100%)
rename airflow/cli/commands/{ => local_commands}/fastapi_api_command.py (97%)
rename airflow/cli/commands/{ => local_commands}/info_command.py (100%)
rename airflow/cli/commands/{ => local_commands}/kerberos_command.py (94%)
rename airflow/cli/commands/{ => local_commands}/plugins_command.py (100%)
rename airflow/cli/commands/{ => local_commands}/rotate_fernet_key_command.py
(100%)
rename airflow/cli/commands/{ => local_commands}/scheduler_command.py (97%)
rename airflow/cli/commands/{ => local_commands}/standalone_command.py (100%)
rename airflow/cli/commands/{ => local_commands}/triggerer_command.py (96%)
rename airflow/cli/commands/{ => local_commands}/webserver_command.py (99%)
copy airflow/{api_connexion => cli/commands/remote_commands}/__init__.py (100%)
rename airflow/cli/commands/{ => remote_commands}/asset_command.py (63%)
rename airflow/cli/commands/{ => remote_commands}/backfill_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/config_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/connection_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/dag_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/jobs_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/pool_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/provider_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/task_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/variable_command.py (100%)
rename airflow/cli/commands/{ => remote_commands}/version_command.py (100%)
create mode 100644 airflow/migrations/versions/0050_3_0_0_add_dagbundlemodel.py
create mode 100644 airflow/models/dagbundle.py
copy {airflow/api_connexion => tests/cli/commands/hybrid_commands}/__init__.py
(100%)
rename tests/cli/commands/{ => hybrid_commands}/test_kubernetes_command.py
(93%)
copy {airflow/api_connexion => tests/cli/commands/local_commands}/__init__.py
(100%)
rename tests/cli/commands/{ => local_commands}/test_celery_command.py (90%)
rename tests/cli/commands/{ => local_commands}/test_cheat_sheet_command.py
(100%)
rename tests/cli/commands/{ => local_commands}/test_dag_processor_command.py
(92%)
rename tests/cli/commands/{ => local_commands}/test_db_command.py (88%)
rename tests/cli/commands/{ => local_commands}/test_fastapi_api_command.py
(98%)
rename tests/cli/commands/{ => local_commands}/test_info_command.py (97%)
rename tests/cli/commands/{ => local_commands}/test_kerberos_command.py (87%)
rename tests/cli/commands/{ => local_commands}/test_plugins_command.py (93%)
rename tests/cli/commands/{ =>
local_commands}/test_rotate_fernet_key_command.py (98%)
rename tests/cli/commands/{ => local_commands}/test_scheduler_command.py (74%)
rename tests/cli/commands/{ => local_commands}/test_standalone_command.py (97%)
rename tests/cli/commands/{ => local_commands}/test_triggerer_command.py (81%)
rename tests/cli/commands/{ => local_commands}/test_webserver_command.py (94%)
copy {airflow/api_connexion => tests/cli/commands/remote_commands}/__init__.py
(100%)
rename tests/cli/commands/{ => remote_commands}/test_asset_command.py (69%)
rename tests/cli/commands/{ => remote_commands}/test_backfill_command.py (92%)
rename tests/cli/commands/{ => remote_commands}/test_config_command.py (96%)
rename tests/cli/commands/{ => remote_commands}/test_connection_command.py
(99%)
rename tests/cli/commands/{ => remote_commands}/test_dag_command.py (96%)
rename tests/cli/commands/{ => remote_commands}/test_jobs_command.py (99%)
rename tests/cli/commands/{ => remote_commands}/test_pool_command.py (99%)
rename tests/cli/commands/{ => remote_commands}/test_task_command.py (96%)
rename tests/cli/commands/{ => remote_commands}/test_variable_command.py (99%)
rename tests/cli/commands/{ => remote_commands}/test_version_command.py (87%)
