This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard bcbb014a005 Refresh breeze documentation hashes in v3-0-test
discard 8425dbdbb5b Bump task-sdk version to 1.0.0
discard 122197c8ba7 Update RELEASE_NOTES.rst
discard 6a48e1bba06 Update Airflow version to 3.0.0
discard 8298f77ec01 Update default branches for 3-0
add 76a96086b6b Fix get_confluent_token callback for Managed Kafka service
(#48926)
add 23793983669 Deprecate start_sql_job in DataflowHook (#48663)
add e2a466dd151 Update providers metadata 2025-04-14 (#49207)
add e519ca76ddd Fix default value wait_for_operation_result (#49121)
add 0f0662cc326 remove Literal[local] type hint as it is included in str
(#49194)
add b835641f746 Collapse Cadwyn migrations (#49116)
add 959135f8a9f Mark mssql and samba tests as db-tests (#49213)
add fd241fceeac fix(AssetSchedule): fix how asset_expression is accessed
(#49214)
add d61fe47bf63 Improve example docs around SQLExecuteQueryOperator in
Druid/Hive/Impala/Kylin/Pinot (#48856)
add c48744891dc Fix some mistakes in AirbyteJobSensor docs. (#49196)
add cb295c351a0 remove superfluous else block (#49199)
add 80232bd35f5 Update taskflow.rst (#47984)
add 571fce66188 fix(AssetSchedule): use asset.name if exists (#49225)
add c447ad303b9 gate import behind Airflow 2 path (#49209)
add dc5d007fe57 feat: overwrite `get_uri` for `JDBC` (#48915)
add 36deade3fc8 Rename directory for dag processor child process logs
(#49227)
add f89dac92025 Improve logging of abnormal exit codes for supervised
sub-processes. (#49217)
add 9534c0690a9 Update Object Storage tutorial to match learning path tone
(#49170)
add 23965c4aa5c Nuke orm_deserialize_value refs in docs and docstring
(#49220)
add c6beaf0e304 batch processing for updating TI UUIDs (#49015)
add 8615a1fc32b Bump min version of pre-installed providers to latest
(#49222)
add 727ab2dfffd Add note in update_airflow_pyproject_toml.py (#49230)
add 45be7f823f3 feat(dag_dependency): add unresolved asset ref node
(#49231)
new 3deec19300d Update default branches for 3-0
new 15da8ce95df Update Airflow version to 3.0.0
new a5c3f6e3c93 Update RELEASE_NOTES.rst
new 5451c0d72d6 Bump task-sdk version to 1.0.0
new cd134b9812a Refresh breeze documentation hashes in v3-0-test
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 (bcbb014a005)
\
N -- N -- N refs/heads/v3-0-test (cd134b9812a)
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.
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../docs/authoring-and-scheduling/assets.rst | 2 +-
.../docs/authoring-and-scheduling/datasets.rst | 4 +-
.../docs/authoring-and-scheduling/index.rst | 7 +-
airflow-core/docs/best-practices.rst | 8 +-
airflow-core/docs/core-concepts/taskflow.rst | 2 +-
airflow-core/docs/core-concepts/xcoms.rst | 2 -
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/troubleshooting.rst | 6 +-
airflow-core/docs/tutorial/fundamentals.rst | 4 +-
airflow-core/docs/tutorial/objectstorage.rst | 160 +++--
airflow-core/docs/tutorial/taskflow.rst | 774 ++++++---------------
airflow-core/newsfragments/aip-66.significant.rst | 9 +
airflow-core/pyproject.toml | 8 +-
airflow-core/src/airflow/__init__.py | 2 +-
.../src/airflow/api_fastapi/auth/tokens.py | 10 +-
.../src/airflow/api_fastapi/common/parameters.py | 3 +-
.../api_fastapi/core_api/datamodels/dags.py | 2 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 17 +-
.../api_fastapi/core_api/routes/public/log.py | 25 +-
.../core_api/services/public/connections.py | 6 +-
.../api_fastapi/core_api/services/public/pools.py | 6 +-
.../core_api/services/public/variables.py | 6 +-
.../execution_api/datamodels/taskinstance.py | 15 +-
.../execution_api/routes/task_instances.py | 29 -
.../api_fastapi/execution_api/versions/__init__.py | 10 +-
.../execution_api/versions/v2025_03_26.py | 41 --
.../execution_api/versions/v2025_04_10.py | 34 -
.../src/airflow/cli/commands/api_server_command.py | 4 +-
.../src/airflow/cli/commands/config_command.py | 4 +
.../src/airflow/cli/commands/dag_command.py | 7 +-
.../src/airflow/cli/commands/info_command.py | 12 +-
.../src/airflow/cli/commands/task_command.py | 4 +-
.../config_templates/airflow_local_settings.py | 2 -
.../src/airflow/config_templates/config.yml | 24 +-
airflow-core/src/airflow/configuration.py | 16 +-
.../src/airflow/dag_processing/bundles/base.py | 3 +-
airflow-core/src/airflow/dag_processing/manager.py | 4 +-
.../src/airflow/dag_processing/processor.py | 4 +-
.../airflow/example_dags/example_bash_decorator.py | 3 +-
.../example_branch_python_dop_operator_3.py | 3 +-
airflow-core/src/airflow/exceptions.py | 4 +-
.../src/airflow/executors/executor_loader.py | 14 +-
.../src/airflow/executors/executor_utils.py | 3 +-
airflow-core/src/airflow/jobs/job.py | 9 +-
.../src/airflow/jobs/scheduler_job_runner.py | 3 +-
airflow-core/src/airflow/metrics/statsd_logger.py | 3 +-
airflow-core/src/airflow/metrics/validators.py | 6 +-
airflow-core/src/airflow/migrations/env.py | 3 +-
...3_0_0_add_uuid_primary_key_to_task_instance_.py | 32 +-
.../0068_3_0_0_ti_table_id_unique_per_try.py | 3 +-
airflow-core/src/airflow/models/asset.py | 8 +-
airflow-core/src/airflow/models/backfill.py | 47 +-
airflow-core/src/airflow/models/base.py | 29 +-
airflow-core/src/airflow/models/baseoperator.py | 3 +-
airflow-core/src/airflow/models/connection.py | 6 +-
airflow-core/src/airflow/models/dag.py | 5 +-
airflow-core/src/airflow/models/dagbag.py | 2 +-
airflow-core/src/airflow/models/dagcode.py | 3 +-
airflow-core/src/airflow/models/dagrun.py | 5 +-
.../src/airflow/models/renderedtifields.py | 3 +-
airflow-core/src/airflow/models/serialized_dag.py | 11 +-
airflow-core/src/airflow/models/taskinstance.py | 12 +-
airflow-core/src/airflow/models/variable.py | 23 +-
airflow-core/src/airflow/providers_manager.py | 3 +-
airflow-core/src/airflow/secrets/base_secrets.py | 6 +-
airflow-core/src/airflow/serialization/helpers.py | 29 +-
airflow-core/src/airflow/serialization/serde.py | 3 +-
.../airflow/serialization/serialized_objects.py | 4 +-
.../airflow/serialization/serializers/timezone.py | 4 +-
airflow-core/src/airflow/settings.py | 3 +-
airflow-core/src/airflow/timetables/events.py | 7 +-
airflow-core/src/airflow/timetables/trigger.py | 3 +-
airflow-core/src/airflow/traces/otel_tracer.py | 10 +-
.../ui/src/pages/DagsList/AssetSchedule.tsx | 6 +-
airflow-core/src/airflow/utils/dag_cycle_tester.py | 2 +-
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/decorators.py | 4 +-
airflow-core/src/airflow/utils/email.py | 26 +-
airflow-core/src/airflow/utils/file.py | 11 +-
airflow-core/src/airflow/utils/helpers.py | 34 +-
.../src/airflow/utils/log/file_task_handler.py | 3 +-
airflow-core/src/airflow/utils/retries.py | 3 +-
airflow-core/src/airflow/utils/session.py | 5 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 27 +-
airflow-core/src/airflow/utils/timezone.py | 5 +-
.../dags/otel_test_dag_with_pause_between_tasks.py | 7 +-
.../otel/dags/otel_test_dag_with_pause_in_task.py | 7 +-
airflow-core/tests/integration/otel/test_otel.py | 20 +-
.../tests/unit/always/test_providers_manager.py | 7 +-
.../auth/managers/test_base_auth_manager.py | 3 +-
.../unit/api_fastapi/execution_api/test_app.py | 2 +-
.../versions/v2025_03_19/test_task_instances.py | 74 --
.../execution_api/versions/v2025_03_26/__init__.py | 16 -
.../versions/v2025_03_26/test_task_instances.py | 99 ---
airflow-core/tests/unit/assets/test_evaluation.py | 2 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 3 +-
airflow-core/tests/unit/models/test_backfill.py | 5 +-
.../tests/unit/models/test_mappedoperator.py | 19 +-
.../tests/unit/models/test_serialized_dag.py | 9 +-
.../tests/unit/models/test_taskinstance.py | 7 +-
.../unit/serialization/test_dag_serialization.py | 20 +-
.../ti_deps/deps/test_mapped_task_upstream_dep.py | 2 +-
airflow-core/tests/unit/utils/test_task_group.py | 10 +-
airflow-ctl/src/airflowctl/api/client.py | 3 +-
airflow-ctl/src/airflowctl/api/operations.py | 3 +-
dev/airflow-github | 9 +-
.../airflow_breeze/commands/ci_image_commands.py | 45 +-
.../airflow_breeze/commands/developer_commands.py | 5 +-
.../airflow_breeze/commands/kubernetes_commands.py | 14 +-
.../commands/release_management_commands.py | 10 +-
.../src/airflow_breeze/commands/sbom_commands.py | 8 +-
.../src/airflow_breeze/commands/setup_commands.py | 5 +-
.../src/airflow_breeze/params/build_prod_params.py | 3 +-
.../airflow_breeze/params/common_build_params.py | 3 +-
.../src/airflow_breeze/params/shell_params.py | 11 +-
.../prepare_providers/provider_distributions.py | 2 +-
.../prepare_providers/provider_documentation.py | 9 +-
dev/breeze/src/airflow_breeze/utils/cache.py | 3 +-
dev/breeze/src/airflow_breeze/utils/cdxgen.py | 3 +-
dev/breeze/src/airflow_breeze/utils/coertions.py | 5 +-
dev/breeze/src/airflow_breeze/utils/confirm.py | 12 +-
.../airflow_breeze/utils/docker_command_utils.py | 11 +-
.../src/airflow_breeze/utils/docs_publisher.py | 6 +-
dev/breeze/src/airflow_breeze/utils/image.py | 12 +-
.../src/airflow_breeze/utils/kubernetes_utils.py | 18 +-
.../src/airflow_breeze/utils/md5_build_check.py | 13 +-
dev/breeze/src/airflow_breeze/utils/packages.py | 17 +-
dev/breeze/src/airflow_breeze/utils/parallel.py | 3 +-
dev/breeze/src/airflow_breeze/utils/run_tests.py | 3 +-
dev/breeze/src/airflow_breeze/utils/run_utils.py | 52 +-
.../src/airflow_breeze/utils/selective_checks.py | 65 +-
.../src/airflow_breeze/utils/version_utils.py | 9 +-
dev/stats/get_important_pr_candidates.py | 16 +-
.../src/sphinx_exts/docs_build/docs_builder.py | 19 +-
.../src/sphinx_exts/operators_and_hooks_ref.py | 12 +-
.../src/sphinx_exts/removemarktransform.py | 2 +-
.../tests_common/_internals/capture_warnings.py | 4 +-
devel-common/src/tests_common/pytest_plugin.py | 49 +-
devel-common/src/tests_common/test_utils/compat.py | 5 +-
.../test_utils/logging_command_executor.py | 68 +-
.../src/tests_common/test_utils/system_tests.py | 5 +-
docker-tests/tests/docker_tests/command_utils.py | 16 +-
docs/spelling_wordlist.txt | 1 +
generated/provider_metadata.json | 72 ++
.../src/airflow/providers/airbyte/hooks/airbyte.py | 8 +-
.../airflow/providers/airbyte/sensors/airbyte.py | 9 +-
.../alibaba/cloud/log/oss_task_handler.py | 3 +-
.../tests/unit/alibaba/cloud/utils/test_utils.py | 3 +-
.../amazon/aws/auth_manager/cli/avp_commands.py | 33 +-
.../aws/executors/ecs/ecs_executor_config.py | 2 +-
.../providers/amazon/aws/executors/ecs/utils.py | 2 +-
.../airflow/providers/amazon/aws/hooks/athena.py | 2 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 27 +-
.../providers/amazon/aws/hooks/cloud_formation.py | 3 +-
.../airflow/providers/amazon/aws/hooks/datasync.py | 4 +-
.../src/airflow/providers/amazon/aws/hooks/dms.py | 5 +-
.../airflow/providers/amazon/aws/hooks/dynamodb.py | 3 +-
.../src/airflow/providers/amazon/aws/hooks/emr.py | 31 +-
.../src/airflow/providers/amazon/aws/hooks/glue.py | 22 +-
.../src/airflow/providers/amazon/aws/hooks/mwaa.py | 13 +-
.../providers/amazon/aws/hooks/redshift_data.py | 2 +-
.../providers/amazon/aws/hooks/redshift_sql.py | 11 +-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 9 +-
.../providers/amazon/aws/hooks/sagemaker.py | 15 +-
.../amazon/aws/hooks/sagemaker_unified_studio.py | 11 +-
.../airflow/providers/amazon/aws/links/base_aws.py | 4 +-
.../src/airflow/providers/amazon/aws/links/emr.py | 6 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 3 +-
.../providers/amazon/aws/log/s3_task_handler.py | 3 +-
.../providers/amazon/aws/operators/athena.py | 2 +-
.../providers/amazon/aws/operators/batch.py | 4 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 10 +-
.../airflow/providers/amazon/aws/operators/eks.py | 8 +-
.../airflow/providers/amazon/aws/operators/emr.py | 9 +-
.../providers/amazon/aws/operators/neptune.py | 4 +-
.../amazon/aws/operators/redshift_data.py | 3 +-
.../airflow/providers/amazon/aws/operators/s3.py | 22 +-
.../providers/amazon/aws/operators/sagemaker.py | 30 +-
.../amazon/aws/secrets/secrets_manager.py | 3 +-
.../airflow/providers/amazon/aws/sensors/batch.py | 3 +-
.../providers/amazon/aws/sensors/glacier.py | 9 +-
.../airflow/providers/amazon/aws/sensors/glue.py | 15 +-
.../providers/amazon/aws/sensors/glue_crawler.py | 6 +-
.../amazon/aws/sensors/redshift_cluster.py | 2 +-
.../src/airflow/providers/amazon/aws/sensors/s3.py | 3 +-
.../amazon/aws/sensors/sagemaker_unified_studio.py | 9 +-
.../airflow/providers/amazon/aws/sensors/sqs.py | 3 +-
.../amazon/aws/utils/connection_wrapper.py | 2 +-
.../src/airflow/providers/amazon/aws/utils/sqs.py | 3 +-
.../src/airflow/providers/amazon/aws/utils/tags.py | 5 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 3 +-
.../providers/apache/beam/operators/beam.py | 39 +-
.../providers/apache/cassandra/hooks/cassandra.py | 3 +-
providers/apache/druid/docs/operators.rst | 94 ++-
.../airflow/providers/apache/druid/hooks/druid.py | 6 +-
.../tests/system/apache/druid/example_druid.py | 75 ++
.../apache/flink/sensors/flink_kubernetes.py | 7 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 3 +-
providers/apache/hive/docs/operators.rst | 66 +-
.../airflow/providers/apache/hive/hooks/hive.py | 8 +-
.../airflow/providers/apache/hive/macros/hive.py | 14 +-
.../apache/hive/sensors/named_hive_partition.py | 3 +-
.../providers/apache/hive/transfers/s3_to_hive.py | 13 +-
.../hive/tests/system/apache/hive/example_hive.py} | 55 +-
providers/apache/impala/docs/index.rst | 9 +
providers/apache/impala/docs/operators.rst | 74 ++
.../apache/impala/tests/system/apache}/__init__.py | 0
.../impala/tests/system/apache/impala}/__init__.py | 0
.../tests/system/apache/impala/example_impala.py} | 61 +-
.../apache/kafka/hooks/test_producer.py | 7 +-
.../apache/kafka/example_dag_event_listener.py | 9 +-
providers/apache/kylin/docs/index.rst | 1 +
providers/apache/kylin/docs/operators.rst | 75 ++
.../tests/system/apache/kylin/example_kylin.py | 91 +++
.../tests/unit/apache/kylin/hooks/test_kylin.py | 3 +-
.../airflow/providers/apache/livy/hooks/livy.py | 5 +-
.../apache/pinot/docs/{operators.rst => hooks.rst} | 0
providers/apache/pinot/docs/index.rst | 1 +
providers/apache/pinot/docs/operators.rst | 134 ++--
.../tests/system/apache/pinot/example_pinot.py} | 51 +-
.../providers/apache/spark/hooks/spark_submit.py | 7 +-
.../airflow/providers/arangodb/hooks/arangodb.py | 27 +-
.../backcompat/backwards_compat_converters.py | 13 +-
.../kubernetes/executors/kubernetes_executor.py | 2 +-
.../executors/kubernetes_executor_utils.py | 9 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 12 +-
.../cncf/kubernetes/kubernetes_helper_functions.py | 3 +-
.../providers/cncf/kubernetes/operators/job.py | 2 +-
.../providers/cncf/kubernetes/operators/kueue.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 4 +-
.../cncf/kubernetes/operators/resource.py | 3 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 2 +-
.../providers/cncf/kubernetes/pod_generator.py | 11 +-
.../kubernetes/resource_convert/env_variable.py | 2 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 7 +-
.../providers/cncf/kubernetes/triggers/pod.py | 5 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 17 +-
.../tests/unit/cncf/kubernetes/conftest.py | 2 +-
.../airflow/providers/common/io/xcom/backend.py | 7 +-
.../airflow/providers/common/sql/hooks/handlers.py | 6 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 5 +-
.../airflow/providers/common/sql/operators/sql.py | 14 +-
.../airflow/providers/common/sql/sensors/sql.py | 8 +-
.../providers/databricks/hooks/databricks.py | 9 +-
.../providers/databricks/hooks/databricks_base.py | 29 +-
.../providers/databricks/hooks/databricks_sql.py | 8 +-
.../providers/databricks/operators/databricks.py | 17 +-
.../databricks/sensors/databricks_partition.py | 5 +-
.../providers/databricks/utils/databricks.py | 13 +-
.../tests/unit/databricks/hooks/test_databricks.py | 9 +-
.../airflow/providers/dbt/cloud/operators/dbt.py | 49 +-
.../airflow/providers/docker/operators/docker.py | 10 +-
.../providers/docker/operators/docker_swarm.py | 5 +-
.../src/airflow/providers/edge/cli/edge_command.py | 25 +-
.../providers/edge/plugins/edge_executor_plugin.py | 2 +-
.../providers/elasticsearch/log/es_task_handler.py | 6 +-
.../log/elasticmock/fake_elasticsearch.py | 3 +-
.../log/elasticmock/utilities/__init__.py | 2 +-
.../src/airflow/providers/exasol/hooks/exasol.py | 3 +-
.../auth_manager/api/auth/backend/basic_auth.py | 3 +-
.../auth_manager/api/auth/backend/kerberos_auth.py | 4 +-
.../fab/auth_manager/api_fastapi/services/login.py | 3 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 33 +-
.../fab/auth_manager/security_manager/override.py | 37 +-
.../fab/src/airflow/providers/fab/www/auth.py | 14 +-
.../fab/www/extensions/init_appbuilder.py | 3 +-
.../providers/fab/www/extensions/init_views.py | 6 +-
.../fab/src/airflow/providers/fab/www/views.py | 3 +-
providers/fab/tests/unit/fab/decorators.py | 3 +-
.../airflow/providers/facebook/ads/hooks/ads.py | 15 +-
.../providers/google/cloud/hooks/bigquery.py | 6 +-
.../providers/google/cloud/hooks/cloud_batch.py | 7 +-
.../providers/google/cloud/hooks/cloud_sql.py | 75 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 2 +-
.../providers/google/cloud/hooks/compute_ssh.py | 5 +-
.../providers/google/cloud/hooks/dataflow.py | 17 +-
.../providers/google/cloud/hooks/datafusion.py | 7 +-
.../airflow/providers/google/cloud/hooks/dlp.py | 2 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 11 +-
.../google/cloud/hooks/kubernetes_engine.py | 3 +-
.../providers/google/cloud/hooks/managed_kafka.py | 2 +-
.../providers/google/cloud/hooks/mlengine.py | 10 +-
.../providers/google/cloud/hooks/stackdriver.py | 10 +-
.../airflow/providers/google/cloud/hooks/vision.py | 3 +-
.../providers/google/cloud/openlineage/mixins.py | 5 +-
.../providers/google/cloud/operators/alloy_db.py | 3 +-
.../providers/google/cloud/operators/automl.py | 10 +-
.../providers/google/cloud/operators/bigquery.py | 50 +-
.../google/cloud/operators/cloud_batch.py | 28 +-
.../google/cloud/operators/cloud_build.py | 3 +-
.../google/cloud/operators/cloud_composer.py | 52 +-
.../providers/google/cloud/operators/cloud_run.py | 25 +-
.../providers/google/cloud/operators/cloud_sql.py | 91 ++-
.../providers/google/cloud/operators/compute.py | 19 +-
.../providers/google/cloud/operators/dataproc.py | 49 +-
.../providers/google/cloud/operators/functions.py | 12 +-
.../google/cloud/operators/kubernetes_engine.py | 3 +-
.../providers/google/cloud/operators/spanner.py | 62 +-
.../google/cloud/sensors/cloud_composer.py | 8 +-
.../providers/google/cloud/sensors/dataflow.py | 2 +-
.../providers/google/cloud/sensors/dataproc.py | 10 +-
.../airflow/providers/google/cloud/sensors/gcs.py | 31 +-
.../providers/google/cloud/sensors/looker.py | 6 +-
.../providers/google/cloud/sensors/pubsub.py | 27 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 15 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 36 +-
.../google/cloud/transfers/facebook_ads_to_gcs.py | 3 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 28 +-
.../google/cloud/transfers/postgres_to_gcs.py | 5 +-
.../providers/google/cloud/utils/bigquery.py | 12 +-
.../providers/google/cloud/utils/dataform.py | 2 +-
.../google/common/hooks/operation_helpers.py | 3 +-
.../google/common/utils/id_token_credentials.py | 2 +-
.../providers/google/leveldb/hooks/leveldb.py | 9 +-
.../cloud_build/example_cloud_build_trigger.py | 3 +-
.../cloud/cloud_sql/example_cloud_sql_query.py | 21 +-
.../cloud/cloud_sql/example_cloud_sql_query_iam.py | 23 +-
.../cloud/cloud_sql/example_cloud_sql_query_ssl.py | 23 +-
.../example_managed_kafka_consumer_group.py | 6 +-
.../tests/unit/google/cloud/hooks/test_dataflow.py | 38 +-
.../cloud/transfers/test_bigquery_to_bigquery.py | 4 +-
.../hashicorp/_internal_client/vault_client.py | 6 +-
.../airflow/providers/hashicorp/secrets/vault.py | 3 +-
.../http/src/airflow/providers/http/hooks/http.py | 2 +-
.../src/airflow/providers/http/operators/http.py | 3 +-
.../src/airflow/providers/http/sensors/http.py | 2 +-
.../jdbc/src/airflow/providers/jdbc/hooks/jdbc.py | 36 +
providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 67 ++
.../jenkins/operators/jenkins_job_trigger.py | 5 +-
.../airflow/providers/jenkins/sensors/jenkins.py | 11 +-
.../providers/microsoft/azure/hooks/batch.py | 9 +-
.../providers/microsoft/azure/hooks/data_lake.py | 3 +-
.../providers/microsoft/azure/hooks/fileshare.py | 47 +-
.../providers/microsoft/azure/hooks/msgraph.py | 2 +-
.../providers/microsoft/azure/hooks/synapse.py | 3 +-
.../providers/microsoft/azure/hooks/wasb.py | 3 +-
.../providers/microsoft/azure/operators/adx.py | 3 +-
.../azure/operators/container_instances.py | 3 +-
.../providers/microsoft/azure/operators/msgraph.py | 6 +-
.../microsoft/azure/transfers/s3_to_wasb.py | 5 +-
.../src/airflow/providers/microsoft/azure/utils.py | 3 +-
.../tests/unit/microsoft/mssql/hooks/test_mssql.py | 31 +-
.../src/airflow/providers/mongo/hooks/mongo.py | 3 +-
.../src/airflow/providers/mysql/hooks/mysql.py | 3 +-
.../odbc/src/airflow/providers/odbc/hooks/odbc.py | 5 +-
.../src/airflow/providers/openai/hooks/openai.py | 4 +-
.../airflow/providers/openfaas/hooks/openfaas.py | 11 +-
.../providers/openlineage/extractors/manager.py | 7 +-
.../providers/openlineage/plugins/adapter.py | 3 +-
.../airflow/providers/openlineage/utils/spark.py | 2 +-
.../airflow/providers/openlineage/utils/utils.py | 58 +-
.../tests/system/openlineage/operator.py | 4 +-
.../providers/opensearch/hooks/opensearch.py | 2 +-
.../providers/opensearch/log/os_task_handler.py | 3 +-
.../providers/papermill/operators/papermill.py | 3 +-
.../airflow/providers/postgres/hooks/postgres.py | 5 +-
.../src/airflow/providers/presto/hooks/presto.py | 4 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 27 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 17 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 13 +-
.../providers/slack/transfers/sql_to_slack.py | 4 +-
.../src/airflow/providers/slack/utils/__init__.py | 30 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 5 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 5 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 9 +-
.../providers/snowflake/operators/snowflake.py | 4 +-
.../airflow/providers/snowflake/utils/snowpark.py | 3 +-
.../airflow/providers/standard/operators/bash.py | 2 +-
.../providers/standard/operators/latest_only.py | 5 +-
.../airflow/providers/standard/operators/python.py | 11 +-
.../providers/standard/operators/trigger_dagrun.py | 7 +-
.../src/airflow/providers/standard/sensors/bash.py | 10 +-
.../providers/standard/sensors/external_task.py | 59 +-
.../airflow/providers/standard/sensors/python.py | 3 +-
.../airflow/providers/standard/sensors/weekday.py | 3 +-
.../providers/standard/triggers/external_task.py | 3 +-
.../providers/standard/triggers/temporal.py | 5 +-
.../providers/standard/utils/python_virtualenv.py | 2 +-
.../standard/decorators/test_external_python.py | 3 +-
.../standard/decorators/test_python_virtualenv.py | 3 +-
.../tests/unit/standard/operators/test_python.py | 6 +-
.../teradata/operators/teradata_compute_cluster.py | 32 +-
.../src/airflow/providers/trino/hooks/trino.py | 6 +-
.../airflow/providers/weaviate/hooks/weaviate.py | 5 +-
pyproject.toml | 4 +
scripts/ci/pre_commit/check_deprecations.py | 7 +-
scripts/ci/pre_commit/check_integrations_list.py | 5 +-
scripts/ci/pre_commit/checkout_no_credentials.py | 14 +-
scripts/ci/pre_commit/generate_pypi_readme.py | 3 +-
.../ci/pre_commit/update_airflow_pyproject_toml.py | 2 +
scripts/ci/pre_commit/update_example_dags_paths.py | 9 +-
.../pre_commit/update_installers_and_pre_commit.py | 4 +-
scripts/ci/testing/summarize_captured_warnings.py | 2 +-
scripts/in_container/verify_providers.py | 3 +-
task-sdk/src/airflow/sdk/api/client.py | 3 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 2 +-
task-sdk/src/airflow/sdk/bases/decorator.py | 6 +-
task-sdk/src/airflow/sdk/bases/operator.py | 14 +-
task-sdk/src/airflow/sdk/bases/sensor.py | 10 +-
task-sdk/src/airflow/sdk/bases/xcom.py | 9 +-
.../src/airflow/sdk/definitions/_internal/node.py | 8 +-
.../airflow/sdk/definitions/_internal/templater.py | 8 +-
.../src/airflow/sdk/definitions/asset/__init__.py | 2 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 24 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 4 +-
task-sdk/src/airflow/sdk/definitions/xcom_arg.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 4 +-
.../airflow/sdk/execution_time/lazy_sequence.py | 9 +-
.../airflow/sdk/execution_time/secrets_masker.py | 20 +-
.../src/airflow/sdk/execution_time/supervisor.py | 87 ++-
.../src/airflow/sdk/execution_time/task_runner.py | 4 +-
task-sdk/src/airflow/sdk/io/path.py | 12 +-
task-sdk/src/airflow/sdk/io/store.py | 2 +-
task-sdk/src/airflow/sdk/log.py | 103 +--
task-sdk/tests/task_sdk/api/test_client.py | 2 +-
.../definitions/decorators/test_setup_teardown.py | 17 +-
task-sdk/tests/task_sdk/definitions/test_asset.py | 2 +-
.../task_sdk/definitions/test_mappedoperator.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_mixins.py | 17 +-
.../task_sdk/execution_time/test_supervisor.py | 166 ++---
.../task_sdk/execution_time/test_task_runner.py | 6 +-
421 files changed, 3085 insertions(+), 3506 deletions(-)
delete mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_03_26.py
delete mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_04_10.py
delete mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2025_03_19/test_task_instances.py
delete mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2025_03_26/__init__.py
delete mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2025_03_26/test_task_instances.py
create mode 100644
providers/apache/druid/tests/system/apache/druid/example_druid.py
copy providers/{presto/tests/system/presto/example_presto.py =>
apache/hive/tests/system/apache/hive/example_hive.py} (55%)
create mode 100644 providers/apache/impala/docs/operators.rst
copy {airflow-core/tests/integration =>
providers/apache/impala/tests/system/apache}/__init__.py (100%)
rename {airflow-core/tests/unit/api_fastapi/execution_api/versions/v2025_03_19
=> providers/apache/impala/tests/system/apache/impala}/__init__.py (100%)
copy providers/{presto/tests/system/presto/example_presto.py =>
apache/impala/tests/system/apache/impala/example_impala.py} (52%)
create mode 100644 providers/apache/kylin/docs/operators.rst
create mode 100644
providers/apache/kylin/tests/system/apache/kylin/example_kylin.py
copy providers/apache/pinot/docs/{operators.rst => hooks.rst} (100%)
copy providers/{presto/tests/system/presto/example_presto.py =>
apache/pinot/tests/system/apache/pinot/example_pinot.py} (54%)
