This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch test-image-cache
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit d45e1d4e7e Test image check
add 671ba75738 Revert "Support encryption for triggers parameters
(#36492)" (#38253)
add 0a74928894 Bump ruff to 0.3.3 (#38240)
add 8831db299c Ignore #38240 from git blame (#38256)
add edbe8602fd Disable coverage for Python 3.12 (#38255)
add f5b3426360 Temporarily disable cache pushing from CI (#38258)
add 10e1046cc0 Test image check
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 (d45e1d4e7e)
\
N -- N -- N refs/heads/test-image-cache (10e1046cc0)
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:
.git-blame-ignore-revs | 3 +
.github/workflows/ci.yml | 148 ++++++++++-----------
.github/workflows/early-image-checks.yml | 129 ------------------
.github/workflows/finalize-tests.yml | 42 +++---
.github/workflows/push-image-cache.yml | 14 +-
.pre-commit-config.yaml | 4 +-
airflow/__main__.py | 1 +
airflow/api/__init__.py | 1 +
airflow/api/auth/backend/basic_auth.py | 1 +
airflow/api/auth/backend/default.py | 1 +
airflow/api/auth/backend/deny_all.py | 1 +
airflow/api/auth/backend/session.py | 1 +
airflow/api/client/__init__.py | 1 +
airflow/api/client/api_client.py | 1 +
airflow/api/client/json_client.py | 1 +
airflow/api/client/local_client.py | 1 +
airflow/api/common/delete_dag.py | 1 +
airflow/api/common/experimental/__init__.py | 1 +
airflow/api/common/experimental/delete_dag.py | 1 +
airflow/api/common/experimental/get_code.py | 1 +
.../api/common/experimental/get_dag_run_state.py | 1 +
airflow/api/common/experimental/get_dag_runs.py | 1 +
airflow/api/common/experimental/get_lineage.py | 1 +
airflow/api/common/experimental/get_task.py | 1 +
.../api/common/experimental/get_task_instance.py | 1 +
airflow/api/common/experimental/mark_tasks.py | 1 +
airflow/api/common/experimental/pool.py | 1 +
airflow/api/common/experimental/trigger_dag.py | 1 +
airflow/api/common/mark_tasks.py | 1 +
airflow/api/common/trigger_dag.py | 1 +
.../managers/fab/api/auth/backend/basic_auth.py | 1 +
.../managers/fab/api/auth/backend/kerberos_auth.py | 1 +
airflow/auth/managers/models/base_user.py | 6 +-
airflow/cli/commands/celery_command.py | 1 +
airflow/cli/commands/config_command.py | 1 +
airflow/cli/commands/connection_command.py | 1 +
airflow/cli/commands/dag_command.py | 1 +
airflow/cli/commands/dag_processor_command.py | 1 +
airflow/cli/commands/db_command.py | 1 +
airflow/cli/commands/info_command.py | 1 +
airflow/cli/commands/internal_api_command.py | 1 +
airflow/cli/commands/kerberos_command.py | 1 +
airflow/cli/commands/kubernetes_command.py | 1 +
airflow/cli/commands/pool_command.py | 1 +
airflow/cli/commands/provider_command.py | 1 +
airflow/cli/commands/rotate_fernet_key_command.py | 1 +
airflow/cli/commands/scheduler_command.py | 1 +
airflow/cli/commands/task_command.py | 4 +-
airflow/cli/commands/triggerer_command.py | 1 +
airflow/cli/commands/variable_command.py | 1 +
airflow/cli/commands/version_command.py | 1 +
airflow/cli/commands/webserver_command.py | 1 +
airflow/config_templates/airflow_local_settings.py | 1 +
.../config_templates/default_webserver_config.py | 1 +
airflow/configuration.py | 12 +-
airflow/contrib/hooks/__init__.py | 1 +
airflow/contrib/operators/__init__.py | 1 +
airflow/contrib/secrets/__init__.py | 1 +
airflow/contrib/sensors/__init__.py | 1 +
airflow/contrib/task_runner/__init__.py | 1 +
airflow/contrib/utils/__init__.py | 1 +
airflow/contrib/utils/log/__init__.py | 1 +
airflow/dag_processing/manager.py | 1 +
airflow/decorators/base.py | 21 +--
airflow/decorators/task_group.py | 6 +-
airflow/example_dags/example_bash_operator.py | 1 +
.../example_branch_datetime_operator.py | 1 +
.../example_branch_day_of_week_operator.py | 1 +
airflow/example_dags/example_branch_labels.py | 1 +
airflow/example_dags/example_branch_operator.py | 1 +
.../example_branch_operator_decorator.py | 1 +
.../example_branch_python_dop_operator_3.py | 1 +
airflow/example_dags/example_complex.py | 1 +
airflow/example_dags/example_datasets.py | 1 +
.../example_dags/example_dynamic_task_mapping.py | 1 +
...amic_task_mapping_with_no_taskflow_operators.py | 1 +
.../example_external_task_marker_dag.py | 1 +
.../example_dags/example_kubernetes_executor.py | 1 +
airflow/example_dags/example_latest_only.py | 1 +
.../example_latest_only_with_trigger.py | 1 +
.../example_local_kubernetes_executor.py | 1 +
airflow/example_dags/example_nested_branch_dag.py | 1 +
airflow/example_dags/example_params_trigger_ui.py | 1 +
airflow/example_dags/example_params_ui_tutorial.py | 1 +
.../example_passing_params_via_test_command.py | 1 +
airflow/example_dags/example_python_decorator.py | 1 +
airflow/example_dags/example_python_operator.py | 1 +
airflow/example_dags/example_setup_teardown.py | 1 +
.../example_setup_teardown_taskflow.py | 1 +
.../example_short_circuit_decorator.py | 1 +
.../example_dags/example_short_circuit_operator.py | 1 +
airflow/example_dags/example_skip_dag.py | 1 +
airflow/example_dags/example_sla_dag.py | 1 +
airflow/example_dags/example_subdag_operator.py | 1 +
airflow/example_dags/example_task_group.py | 1 +
.../example_dags/example_task_group_decorator.py | 1 +
.../example_time_delta_sensor_async.py | 1 +
.../example_dags/example_trigger_controller_dag.py | 1 +
airflow/example_dags/example_trigger_target_dag.py | 1 +
airflow/example_dags/example_xcom.py | 1 +
airflow/example_dags/example_xcomargs.py | 1 +
airflow/example_dags/plugins/workday.py | 1 +
airflow/example_dags/subdags/subdag.py | 1 +
airflow/example_dags/tutorial.py | 1 +
airflow/example_dags/tutorial_dag.py | 1 +
airflow/exceptions.py | 1 +
airflow/executors/__init__.py | 1 +
airflow/executors/base_executor.py | 1 +
airflow/executors/debug_executor.py | 1 +
airflow/executors/executor_loader.py | 1 +
airflow/executors/local_executor.py | 1 +
airflow/executors/sequential_executor.py | 1 +
airflow/hooks/__init__.py | 1 +
airflow/hooks/base.py | 1 +
airflow/hooks/dbapi.py | 1 +
airflow/hooks/package_index.py | 1 +
airflow/jobs/triggerer_job_runner.py | 27 +---
.../pre_7_4_0_compatibility/k8s_model.py | 1 +
.../pre_7_4_0_compatibility/kube_client.py | 1 +
.../pre_7_4_0_compatibility/pod_generator.py | 1 +
.../pod_generator_deprecated.py | 1 +
.../kubernetes/pre_7_4_0_compatibility/secret.py | 1 +
airflow/lineage/__init__.py | 1 +
airflow/lineage/backend.py | 1 +
airflow/lineage/entities.py | 1 +
airflow/metrics/protocols.py | 6 +-
airflow/models/__init__.py | 1 +
airflow/models/baseoperator.py | 1 +
airflow/models/dag.py | 6 +-
airflow/models/dagparam.py | 1 +
airflow/models/dagrun.py | 6 +-
airflow/models/renderedtifields.py | 1 +
airflow/models/serialized_dag.py | 1 +
airflow/models/taskfail.py | 1 +
airflow/models/taskmap.py | 1 +
airflow/models/taskreschedule.py | 1 +
airflow/models/trigger.py | 13 +-
airflow/operators/branch.py | 1 +
airflow/operators/latest_only.py | 1 +
airflow/operators/subdag.py | 1 +
airflow/plugins_manager.py | 1 +
airflow/providers/airbyte/sensors/airbyte.py | 1 +
.../alibaba/cloud/operators/analyticdb_spark.py | 3 +-
airflow/providers/alibaba/cloud/operators/oss.py | 1 +
.../amazon/aws/auth_manager/cli/avp_commands.py | 1 +
.../amazon/aws/auth_manager/cli/idc_commands.py | 1 +
.../amazon/aws/executors/batch/batch_executor.py | 1 +
airflow/providers/amazon/aws/hooks/athena.py | 1 +
airflow/providers/amazon/aws/hooks/base_aws.py | 1 +
airflow/providers/amazon/aws/hooks/batch_client.py | 1 +
.../providers/amazon/aws/hooks/batch_waiters.py | 1 +
airflow/providers/amazon/aws/hooks/chime.py | 1 +
.../providers/amazon/aws/hooks/cloud_formation.py | 1 +
airflow/providers/amazon/aws/hooks/datasync.py | 1 +
airflow/providers/amazon/aws/hooks/dynamodb.py | 1 +
airflow/providers/amazon/aws/hooks/eks.py | 1 +
airflow/providers/amazon/aws/hooks/glue_catalog.py | 1 +
airflow/providers/amazon/aws/hooks/kinesis.py | 1 +
.../providers/amazon/aws/hooks/lambda_function.py | 1 +
airflow/providers/amazon/aws/hooks/rds.py | 1 +
airflow/providers/amazon/aws/hooks/s3.py | 1 +
airflow/providers/amazon/aws/hooks/ses.py | 1 +
airflow/providers/amazon/aws/hooks/sns.py | 1 +
airflow/providers/amazon/aws/hooks/sqs.py | 1 +
airflow/providers/amazon/aws/operators/batch.py | 1 +
.../amazon/aws/operators/cloud_formation.py | 1 +
airflow/providers/amazon/aws/operators/datasync.py | 1 +
airflow/providers/amazon/aws/operators/eks.py | 1 +
airflow/providers/amazon/aws/operators/s3.py | 1 +
airflow/providers/amazon/aws/operators/sns.py | 1 +
airflow/providers/amazon/aws/operators/sqs.py | 1 +
.../amazon/aws/secrets/secrets_manager.py | 1 +
.../amazon/aws/secrets/systems_manager.py | 1 +
.../amazon/aws/sensors/cloud_formation.py | 1 +
airflow/providers/amazon/aws/sensors/eks.py | 7 +-
airflow/providers/amazon/aws/sensors/sqs.py | 1 +
airflow/providers/amazon/aws/transfers/base.py | 1 +
.../providers/amazon/aws/transfers/exasol_to_s3.py | 1 +
.../providers/amazon/aws/transfers/gcs_to_s3.py | 1 +
.../amazon/aws/transfers/google_api_to_s3.py | 1 +
.../amazon/aws/transfers/hive_to_dynamodb.py | 1 +
.../providers/amazon/aws/transfers/http_to_s3.py | 1 +
.../amazon/aws/transfers/imap_attachment_to_s3.py | 1 +
.../amazon/aws/transfers/redshift_to_s3.py | 1 +
airflow/providers/amazon/aws/utils/emailer.py | 1 +
airflow/providers/apache/beam/hooks/beam.py | 1 +
airflow/providers/apache/beam/operators/beam.py | 10 +-
.../providers/apache/cassandra/hooks/cassandra.py | 1 +
.../apache/druid/transfers/hive_to_druid.py | 1 +
airflow/providers/apache/hdfs/hooks/webhdfs.py | 1 +
.../apache/hive/transfers/hive_to_mysql.py | 1 +
.../apache/hive/transfers/hive_to_samba.py | 1 +
.../apache/hive/transfers/mssql_to_hive.py | 1 +
.../apache/hive/transfers/mysql_to_hive.py | 1 +
.../providers/apache/hive/transfers/s3_to_hive.py | 1 +
.../apache/hive/transfers/vertica_to_hive.py | 1 +
airflow/providers/apache/livy/hooks/livy.py | 1 +
airflow/providers/apache/livy/operators/livy.py | 1 +
airflow/providers/apache/livy/sensors/livy.py | 1 +
airflow/providers/apache/livy/triggers/livy.py | 1 +
airflow/providers/arangodb/hooks/arangodb.py | 1 +
airflow/providers/asana/hooks/asana.py | 1 +
airflow/providers/atlassian/jira/hooks/jira.py | 1 +
airflow/providers/celery/cli/celery_command.py | 1 +
.../providers/celery/executors/celery_executor.py | 1 +
.../providers/celery/executors/default_celery.py | 1 +
airflow/providers/cloudant/hooks/cloudant.py | 1 +
.../backcompat/backwards_compat_converters.py | 1 +
.../kubernetes/executors/kubernetes_executor.py | 1 +
airflow/providers/cncf/kubernetes/k8s_model.py | 1 +
airflow/providers/cncf/kubernetes/kube_client.py | 1 +
.../kubernetes/operators/custom_object_launcher.py | 1 +
airflow/providers/cncf/kubernetes/operators/job.py | 1 +
.../cncf/kubernetes/operators/kubernetes_pod.py | 1 +
airflow/providers/cncf/kubernetes/pod_generator.py | 1 +
.../cncf/kubernetes/pod_generator_deprecated.py | 1 +
.../cncf/kubernetes/pod_launcher_deprecated.py | 1 +
.../cncf/kubernetes/python_kubernetes_script.py | 1 +
airflow/providers/cncf/kubernetes/secret.py | 1 +
.../cncf/kubernetes/triggers/kubernetes_pod.py | 1 +
.../providers/cncf/kubernetes/utils/pod_manager.py | 1 +
.../cncf/kubernetes/utils/xcom_sidecar.py | 1 +
airflow/providers/common/sql/hooks/sql.py | 6 +-
airflow/providers/databricks/hooks/databricks.py | 1 +
.../providers/databricks/hooks/databricks_base.py | 1 +
.../providers/databricks/hooks/databricks_sql.py | 6 +-
.../providers/databricks/operators/databricks.py | 1 +
.../databricks/operators/databricks_repos.py | 1 +
.../databricks/operators/databricks_sql.py | 1 +
airflow/providers/docker/exceptions.py | 1 +
airflow/providers/docker/operators/docker.py | 1 +
airflow/providers/docker/operators/docker_swarm.py | 1 +
airflow/providers/exasol/hooks/exasol.py | 6 +-
.../auth_manager/api/auth/backend/basic_auth.py | 1 +
.../fab/auth_manager/cli_commands/role_command.py | 1 +
.../auth_manager/cli_commands/sync_perm_command.py | 1 +
.../fab/auth_manager/cli_commands/user_command.py | 1 +
airflow/providers/facebook/ads/hooks/ads.py | 1 +
airflow/providers/ftp/operators/ftp.py | 1 +
airflow/providers/github/hooks/github.py | 1 +
airflow/providers/google/ads/hooks/ads.py | 1 +
airflow/providers/google/ads/operators/ads.py | 1 +
.../cloud/example_dags/example_cloud_sql_query.py | 1 +
.../cloud/example_dags/example_cloud_task.py | 1 +
.../example_dags/example_facebook_ads_to_gcs.py | 1 +
.../google/cloud/example_dags/example_looker.py | 1 +
.../cloud/example_dags/example_presto_to_gcs.py | 1 +
.../example_dags/example_salesforce_to_gcs.py | 1 +
airflow/providers/google/cloud/hooks/automl.py | 1 +
.../providers/google/cloud/hooks/bigquery_dts.py | 1 +
airflow/providers/google/cloud/hooks/bigtable.py | 1 +
.../providers/google/cloud/hooks/cloud_build.py | 1 +
.../google/cloud/hooks/cloud_memorystore.py | 1 +
airflow/providers/google/cloud/hooks/cloud_sql.py | 1 +
airflow/providers/google/cloud/hooks/compute.py | 1 +
airflow/providers/google/cloud/hooks/dataflow.py | 1 +
airflow/providers/google/cloud/hooks/datafusion.py | 1 +
.../providers/google/cloud/hooks/datapipeline.py | 1 +
airflow/providers/google/cloud/hooks/dataplex.py | 1 +
airflow/providers/google/cloud/hooks/dataprep.py | 1 +
airflow/providers/google/cloud/hooks/dataproc.py | 1 +
.../google/cloud/hooks/dataproc_metastore.py | 1 +
airflow/providers/google/cloud/hooks/datastore.py | 1 +
airflow/providers/google/cloud/hooks/dlp.py | 1 +
airflow/providers/google/cloud/hooks/functions.py | 1 +
airflow/providers/google/cloud/hooks/gcs.py | 7 +-
airflow/providers/google/cloud/hooks/kms.py | 1 +
.../google/cloud/hooks/kubernetes_engine.py | 1 +
.../providers/google/cloud/hooks/life_sciences.py | 1 +
airflow/providers/google/cloud/hooks/looker.py | 1 +
airflow/providers/google/cloud/hooks/mlengine.py | 1 +
.../google/cloud/hooks/natural_language.py | 1 +
airflow/providers/google/cloud/hooks/os_login.py | 1 +
airflow/providers/google/cloud/hooks/pubsub.py | 1 +
.../providers/google/cloud/hooks/secret_manager.py | 1 +
airflow/providers/google/cloud/hooks/spanner.py | 1 +
.../providers/google/cloud/hooks/speech_to_text.py | 1 +
.../providers/google/cloud/hooks/stackdriver.py | 1 +
.../providers/google/cloud/hooks/text_to_speech.py | 1 +
airflow/providers/google/cloud/hooks/translate.py | 1 +
.../google/cloud/hooks/vertex_ai/auto_ml.py | 1 +
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 1 +
.../google/cloud/hooks/vertex_ai/custom_job.py | 1 +
.../google/cloud/hooks/vertex_ai/dataset.py | 1 +
.../cloud/hooks/vertex_ai/endpoint_service.py | 1 +
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 1 +
.../google/cloud/hooks/vertex_ai/pipeline_job.py | 1 +
.../google/cloud/hooks/video_intelligence.py | 1 +
airflow/providers/google/cloud/hooks/vision.py | 1 +
airflow/providers/google/cloud/links/automl.py | 1 +
airflow/providers/google/cloud/links/bigquery.py | 1 +
.../providers/google/cloud/links/bigquery_dts.py | 1 +
.../google/cloud/links/cloud_memorystore.py | 1 +
airflow/providers/google/cloud/links/cloud_sql.py | 1 +
.../providers/google/cloud/links/cloud_tasks.py | 1 +
airflow/providers/google/cloud/links/compute.py | 1 +
.../providers/google/cloud/links/datacatalog.py | 1 +
airflow/providers/google/cloud/links/dataflow.py | 1 +
airflow/providers/google/cloud/links/dataform.py | 1 +
airflow/providers/google/cloud/links/datafusion.py | 1 +
airflow/providers/google/cloud/links/dataplex.py | 1 +
airflow/providers/google/cloud/links/dataproc.py | 1 +
airflow/providers/google/cloud/links/mlengine.py | 1 +
airflow/providers/google/cloud/links/pubsub.py | 1 +
airflow/providers/google/cloud/links/spanner.py | 1 +
.../providers/google/cloud/links/stackdriver.py | 1 +
airflow/providers/google/cloud/links/workflows.py | 1 +
.../google/cloud/log/stackdriver_task_handler.py | 1 +
airflow/providers/google/cloud/operators/automl.py | 1 +
.../providers/google/cloud/operators/bigquery.py | 1 +
.../google/cloud/operators/bigquery_dts.py | 1 +
.../providers/google/cloud/operators/bigtable.py | 1 +
.../providers/google/cloud/operators/cloud_base.py | 1 +
.../google/cloud/operators/cloud_build.py | 1 +
.../google/cloud/operators/cloud_memorystore.py | 1 +
.../providers/google/cloud/operators/cloud_sql.py | 1 +
.../operators/cloud_storage_transfer_service.py | 1 +
.../providers/google/cloud/operators/compute.py | 1 +
.../providers/google/cloud/operators/dataflow.py | 1 +
.../providers/google/cloud/operators/datafusion.py | 1 +
.../google/cloud/operators/datapipeline.py | 1 +
.../providers/google/cloud/operators/dataprep.py | 1 +
.../providers/google/cloud/operators/dataproc.py | 1 +
.../google/cloud/operators/dataproc_metastore.py | 1 +
.../providers/google/cloud/operators/datastore.py | 1 +
.../providers/google/cloud/operators/functions.py | 1 +
airflow/providers/google/cloud/operators/gcs.py | 1 +
.../google/cloud/operators/kubernetes_engine.py | 1 +
.../google/cloud/operators/life_sciences.py | 1 +
airflow/providers/google/cloud/operators/looker.py | 1 +
.../google/cloud/operators/natural_language.py | 1 +
airflow/providers/google/cloud/operators/pubsub.py | 1 +
.../providers/google/cloud/operators/spanner.py | 1 +
.../google/cloud/operators/speech_to_text.py | 1 +
.../google/cloud/operators/text_to_speech.py | 1 +
.../providers/google/cloud/operators/translate.py | 1 +
.../google/cloud/operators/translate_speech.py | 1 +
.../google/cloud/operators/vertex_ai/custom_job.py | 1 +
.../google/cloud/operators/vertex_ai/dataset.py | 1 +
.../cloud/operators/vertex_ai/pipeline_job.py | 1 +
.../google/cloud/operators/video_intelligence.py | 1 +
airflow/providers/google/cloud/operators/vision.py | 1 +
.../google/cloud/secrets/secret_manager.py | 1 +
airflow/providers/google/cloud/sensors/bigquery.py | 1 +
.../providers/google/cloud/sensors/bigquery_dts.py | 1 +
airflow/providers/google/cloud/sensors/bigtable.py | 1 +
.../sensors/cloud_storage_transfer_service.py | 1 +
airflow/providers/google/cloud/sensors/dataflow.py | 1 +
airflow/providers/google/cloud/sensors/dataform.py | 1 +
.../providers/google/cloud/sensors/datafusion.py | 1 +
airflow/providers/google/cloud/sensors/dataplex.py | 1 +
airflow/providers/google/cloud/sensors/dataprep.py | 1 +
airflow/providers/google/cloud/sensors/dataproc.py | 1 +
airflow/providers/google/cloud/sensors/gcs.py | 1 +
airflow/providers/google/cloud/sensors/looker.py | 1 +
airflow/providers/google/cloud/sensors/pubsub.py | 1 +
airflow/providers/google/cloud/sensors/tasks.py | 1 +
.../google/cloud/transfers/bigquery_to_bigquery.py | 1 +
.../google/cloud/transfers/bigquery_to_gcs.py | 1 +
.../google/cloud/transfers/bigquery_to_mssql.py | 1 +
.../google/cloud/transfers/bigquery_to_mysql.py | 1 +
.../google/cloud/transfers/bigquery_to_postgres.py | 1 +
.../google/cloud/transfers/bigquery_to_sql.py | 1 +
.../google/cloud/transfers/facebook_ads_to_gcs.py | 1 +
.../google/cloud/transfers/gcs_to_bigquery.py | 1 +
.../providers/google/cloud/transfers/gcs_to_gcs.py | 1 +
.../google/cloud/transfers/gcs_to_sftp.py | 1 +
.../google/cloud/transfers/local_to_gcs.py | 1 +
.../google/cloud/transfers/mssql_to_gcs.py | 1 +
.../google/cloud/transfers/mysql_to_gcs.py | 1 +
.../google/cloud/transfers/postgres_to_gcs.py | 1 +
.../google/cloud/transfers/sftp_to_gcs.py | 1 +
.../providers/google/cloud/transfers/sql_to_gcs.py | 1 +
.../providers/google/cloud/triggers/cloud_sql.py | 1 +
.../providers/google/cloud/triggers/dataplex.py | 1 +
.../providers/google/cloud/triggers/dataproc.py | 1 +
airflow/providers/google/cloud/triggers/pubsub.py | 1 +
.../google/cloud/utils/field_sanitizer.py | 3 +-
.../google/cloud/utils/field_validator.py | 1 +
airflow/providers/google/cloud/utils/helpers.py | 1 +
.../google/cloud/utils/mlengine_operator_utils.py | 1 +
.../cloud/utils/mlengine_prediction_summary.py | 1 +
.../providers/google/cloud/utils/openlineage.py | 1 +
.../google/common/auth_backend/google_openid.py | 1 +
.../providers/google/common/hooks/base_google.py | 1 +
.../providers/google/common/hooks/discovery_api.py | 1 +
airflow/providers/google/common/links/storage.py | 1 +
.../google/common/utils/id_token_credentials.py | 1 +
.../providers/google/firebase/hooks/firestore.py | 1 +
airflow/providers/google/go_module_utils.py | 1 +
airflow/providers/google/leveldb/hooks/leveldb.py | 1 +
.../example_dags/example_display_video.py | 1 +
.../marketing_platform/hooks/analytics_admin.py | 1 +
.../marketing_platform/hooks/campaign_manager.py | 1 +
.../marketing_platform/hooks/display_video.py | 1 +
.../google/marketing_platform/hooks/search_ads.py | 1 +
.../marketing_platform/operators/analytics.py | 1 +
.../operators/analytics_admin.py | 1 +
.../operators/campaign_manager.py | 1 +
.../marketing_platform/operators/display_video.py | 1 +
.../marketing_platform/operators/search_ads.py | 1 +
.../marketing_platform/sensors/campaign_manager.py | 1 +
.../marketing_platform/sensors/display_video.py | 1 +
.../marketing_platform/sensors/search_ads.py | 1 +
airflow/providers/google/suite/hooks/calendar.py | 1 +
airflow/providers/google/suite/hooks/drive.py | 1 +
airflow/providers/google/suite/hooks/sheets.py | 1 +
airflow/providers/google/suite/sensors/drive.py | 1 +
.../google/suite/transfers/gcs_to_gdrive.py | 1 +
.../google/suite/transfers/local_to_drive.py | 1 +
airflow/providers/grpc/hooks/grpc.py | 1 +
airflow/providers/hashicorp/hooks/vault.py | 1 +
airflow/providers/hashicorp/secrets/vault.py | 1 +
airflow/providers/imap/hooks/imap.py | 1 +
airflow/providers/imap/sensors/imap_attachment.py | 1 +
airflow/providers/influxdb/hooks/influxdb.py | 1 +
airflow/providers/microsoft/azure/hooks/adx.py | 1 +
.../microsoft/azure/hooks/container_registry.py | 1 +
airflow/providers/microsoft/azure/hooks/cosmos.py | 1 +
.../microsoft/azure/hooks/data_factory.py | 1 +
airflow/providers/microsoft/azure/hooks/wasb.py | 1 +
airflow/providers/microsoft/azure/operators/adx.py | 1 +
.../microsoft/azure/transfers/sftp_to_wasb.py | 1 +
airflow/providers/microsoft/mssql/hooks/mssql.py | 1 +
airflow/providers/microsoft/winrm/hooks/winrm.py | 1 +
airflow/providers/mongo/hooks/mongo.py | 7 +-
airflow/providers/mysql/hooks/mysql.py | 1 +
airflow/providers/neo4j/hooks/neo4j.py | 1 +
airflow/providers/odbc/hooks/odbc.py | 1 +
airflow/providers/openlineage/extractors/base.py | 3 +-
airflow/providers/pagerduty/hooks/pagerduty.py | 1 +
.../providers/pagerduty/hooks/pagerduty_events.py | 1 +
airflow/providers/pinecone/hooks/pinecone.py | 1 +
.../providers/presto/transfers/gcs_to_presto.py | 1 +
airflow/providers/redis/hooks/redis.py | 1 +
airflow/providers/salesforce/hooks/salesforce.py | 1 +
airflow/providers/samba/transfers/gcs_to_samba.py | 1 +
airflow/providers/segment/hooks/segment.py | 1 +
airflow/providers/sendgrid/utils/emailer.py | 1 +
airflow/providers/sftp/hooks/sftp.py | 1 +
airflow/providers/sftp/operators/sftp.py | 1 +
airflow/providers/sftp/sensors/sftp.py | 1 +
.../slack/notifications/slack_notifier.py | 1 +
airflow/providers/smtp/hooks/smtp.py | 1 +
airflow/providers/snowflake/hooks/snowflake.py | 6 +-
.../snowflake/transfers/copy_into_snowflake.py | 1 +
airflow/providers/ssh/hooks/ssh.py | 1 +
airflow/providers/telegram/hooks/telegram.py | 1 +
airflow/providers/telegram/operators/telegram.py | 1 +
airflow/providers/teradata/hooks/teradata.py | 1 +
airflow/providers/trino/operators/trino.py | 1 +
airflow/providers/trino/transfers/gcs_to_trino.py | 1 +
airflow/providers/vertica/hooks/vertica.py | 6 +-
airflow/providers/yandex/secrets/lockbox.py | 1 +
airflow/providers_manager.py | 5 +-
airflow/secrets/__init__.py | 1 +
airflow/secrets/environment_variables.py | 1 +
airflow/secrets/local_filesystem.py | 1 +
airflow/secrets/metastore.py | 1 +
airflow/sentry.py | 1 +
airflow/serialization/enums.py | 1 +
airflow/serialization/helpers.py | 1 +
airflow/serialization/json_schema.py | 1 +
airflow/serialization/serialized_objects.py | 1 +
airflow/task/priority_strategy.py | 1 +
airflow/task/task_runner/base_task_runner.py | 1 +
airflow/task/task_runner/cgroup_task_runner.py | 1 +
airflow/task/task_runner/standard_task_runner.py | 1 +
airflow/ti_deps/deps/dagrun_backfill_dep.py | 1 +
airflow/ti_deps/deps/pool_slots_available_dep.py | 1 +
airflow/ti_deps/deps/task_not_running_dep.py | 1 +
airflow/typing_compat.py | 1 +
airflow/utils/cli.py | 1 +
airflow/utils/cli_action_loggers.py | 1 +
airflow/utils/context.py | 1 +
airflow/utils/dag_cycle_tester.py | 1 +
airflow/utils/db_cleanup.py | 1 +
airflow/utils/dot_renderer.py | 1 +
airflow/utils/file.py | 6 +-
airflow/utils/log/colored_log.py | 1 +
airflow/utils/log/file_task_handler.py | 1 +
airflow/utils/log/json_formatter.py | 1 +
airflow/utils/log/secrets_masker.py | 1 +
.../log/task_handler_with_custom_formatter.py | 1 +
airflow/utils/platform.py | 1 +
airflow/utils/process_utils.py | 1 +
airflow/utils/python_virtualenv.py | 1 +
airflow/utils/retries.py | 6 +-
airflow/utils/serve_logs.py | 1 +
airflow/utils/sqlalchemy.py | 12 +-
airflow/utils/strings.py | 1 +
airflow/utils/task_group.py | 1 +
airflow/utils/timezone.py | 24 ++--
airflow/utils/weekday.py | 1 +
airflow/utils/yaml.py | 1 +
dev/assign_cherry_picked_prs_with_milestone.py | 3 +-
dev/breeze/src/airflow_breeze/branch_defaults.py | 1 +
dev/breeze/src/airflow_breeze/global_constants.py | 1 +
dev/breeze/src/airflow_breeze/utils/cache.py | 1 +
dev/breeze/src/airflow_breeze/utils/console.py | 1 +
.../airflow_breeze/utils/docker_command_utils.py | 1 +
.../src/airflow_breeze/utils/host_info_utils.py | 1 +
.../src/airflow_breeze/utils/md5_build_check.py | 1 +
dev/breeze/src/airflow_breeze/utils/path_utils.py | 1 +
dev/breeze/src/airflow_breeze/utils/run_tests.py | 7 +-
dev/breeze/src/airflow_breeze/utils/run_utils.py | 1 +
dev/breeze/src/airflow_breeze/utils/visuals.py | 1 +
dev/chart/build_changelog_annotations.py | 1 +
dev/perf/dags/perf_dag_1.py | 1 +
dev/perf/dags/perf_dag_2.py | 1 +
dev/prepare_bulk_issues.py | 3 +-
...calculate_statistics_provider_testing_issues.py | 3 +-
.../authoring-and-scheduling/deferring.rst | 27 ----
docs/apache-airflow/empty_plugin/empty_plugin.py | 1 +
docs/build_docs.py | 1 +
docs/conf.py | 1 +
.../extending/embedding-dags/test_dag.py | 1 +
docs/exts/docroles.py | 1 +
docs/exts/provider_init_hack.py | 1 +
docs/exts/providers_extensions.py | 1 +
docs/exts/redirects.py | 1 +
docs/exts/removemarktransform.py | 1 +
pyproject.toml | 2 +-
.../pre_commit/pre_commit_changelog_duplicates.py | 1 +
.../pre_commit_check_extra_packages_ref.py | 1 +
.../pre_commit_check_integrations_list.py | 1 +
.../pre_commit_check_order_dockerfile_extras.py | 1 +
.../pre_commit_check_order_pyproject_toml.py | 1 +
.../pre_commit_check_pre_commit_hooks.py | 1 +
scripts/ci/pre_commit/pre_commit_newsfragments.py | 1 +
.../pre_commit_update_chart_dependencies.py | 6 +-
scripts/in_container/run_ci_tests.sh | 12 --
scripts/in_container/run_migration_reference.py | 1 +
scripts/in_container/run_prepare_er_diagram.py | 1 +
.../endpoints/test_plugin_endpoint.py | 9 +-
tests/api_connexion/schemas/test_plugin_schema.py | 9 +-
tests/conftest.py | 22 +--
tests/dags/test_issue_1225.py | 1 +
tests/dags/test_miscellaneous.py | 1 +
tests/dags/test_subdag.py | 1 +
tests/dags/test_task_view_type_check.py | 1 +
tests/decorators/test_bash.py | 3 +-
tests/decorators/test_python.py | 23 ++--
tests/decorators/test_short_circuit.py | 3 +-
tests/decorators/test_task_group.py | 3 +-
tests/hooks/test_package_index.py | 1 +
tests/jobs/test_backfill_job.py | 18 +--
tests/models/test_baseoperator.py | 3 +-
tests/models/test_dag.py | 24 ++--
tests/models/test_dagrun.py | 36 ++---
tests/models/test_mappedoperator.py | 6 +-
tests/models/test_renderedtifields.py | 1 +
tests/models/test_serialized_dag.py | 1 +
tests/models/test_skipmixin.py | 3 +-
tests/models/test_trigger.py | 49 +------
tests/plugins/workday.py | 1 +
.../aws/executors/batch/test_batch_executor.py | 6 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 36 ++---
tests/providers/amazon/aws/hooks/test_s3.py | 8 +-
.../amazon/aws/operators/test_base_aws.py | 3 +-
.../providers/amazon/aws/sensors/test_base_aws.py | 3 +-
.../amazon/aws/system/utils/test_helpers.py | 1 +
.../amazon/aws/transfers/test_exasol_to_s3.py | 1 +
.../amazon/aws/utils/eks_test_constants.py | 1 +
.../cncf/kubernetes/hooks/test_kubernetes.py | 3 +-
.../elasticsearch/log/test_es_task_handler.py | 3 +-
.../google/cloud/hooks/test_bigquery_system.py | 1 +
.../google/cloud/hooks/test_cloud_build.py | 1 +
tests/providers/google/cloud/hooks/test_dlp.py | 1 +
.../google/cloud/hooks/test_life_sciences.py | 1 +
.../google/cloud/operators/test_cloud_build.py | 1 +
.../google/cloud/operators/test_cloud_run.py | 1 +
tests/providers/google/cloud/operators/test_dlp.py | 1 +
.../google/cloud/operators/test_life_sciences.py | 3 +-
.../google/firebase/hooks/test_firestore.py | 1 +
.../providers/google/suite/hooks/test_calendar.py | 1 +
tests/providers/google/suite/hooks/test_sheets.py | 1 +
tests/providers/sendgrid/utils/test_emailer.py | 6 +-
tests/serialization/test_dag_serialization.py | 1 +
.../airbyte/example_airbyte_trigger_job.py | 1 +
.../amazon/aws/example_google_api_sheets_to_s3.py | 1 +
.../amazon/aws/example_google_api_youtube_to_s3.py | 1 +
.../amazon/aws/example_hive_to_dynamodb.py | 7 +-
.../amazon/aws/example_imap_attachment_to_s3.py | 1 +
.../amazon/aws/example_salesforce_to_s3.py | 1 +
tests/system/providers/apache/beam/example_beam.py | 1 +
.../apache/beam/example_beam_java_flink.py | 1 +
.../apache/beam/example_beam_java_spark.py | 1 +
tests/system/providers/apache/beam/example_go.py | 1 +
.../providers/apache/beam/example_go_dataflow.py | 1 +
.../providers/apache/beam/example_java_dataflow.py | 1 +
.../system/providers/apache/beam/example_python.py | 1 +
.../providers/apache/beam/example_python_async.py | 1 +
.../apache/beam/example_python_dataflow.py | 1 +
tests/system/providers/apache/beam/utils.py | 1 +
.../apache/cassandra/example_cassandra_dag.py | 1 +
.../providers/apache/drill/example_drill_dag.py | 1 +
.../providers/apache/druid/example_druid_dag.py | 1 +
.../providers/apache/hive/example_twitter_dag.py | 1 +
.../providers/apache/kylin/example_kylin_dag.py | 1 +
tests/system/providers/apache/livy/example_livy.py | 1 +
tests/system/providers/apache/pig/example_pig.py | 1 +
.../providers/apache/spark/example_spark_dag.py | 1 +
tests/system/providers/asana/example_asana.py | 1 +
.../cncf/kubernetes/example_kubernetes.py | 1 +
.../cncf/kubernetes/example_kubernetes_job.py | 1 +
.../cncf/kubernetes/example_kubernetes_resource.py | 1 +
.../cncf/kubernetes/example_spark_kubernetes.py | 1 +
.../providers/databricks/example_databricks.py | 1 +
.../providers/databricks/example_databricks_sql.py | 1 +
.../system/providers/dingding/example_dingding.py | 1 +
.../providers/docker/example_docker_copy_data.py | 1 +
.../elasticsearch/example_elasticsearch_query.py | 1 +
tests/system/providers/ftp/example_ftp.py | 1 +
tests/system/providers/google/ads/example_ads.py | 1 +
.../google/cloud/automl/example_automl_dataset.py | 1 +
.../google/cloud/automl/example_automl_model.py | 1 +
.../example_automl_nl_text_classification.py | 1 +
.../automl/example_automl_nl_text_extraction.py | 1 +
.../automl/example_automl_nl_text_sentiment.py | 1 +
.../cloud/automl/example_automl_translation.py | 1 +
.../automl/example_automl_video_classification.py | 1 +
.../cloud/automl/example_automl_video_tracking.py | 1 +
.../automl/example_automl_vision_classification.py | 1 +
.../example_automl_vision_object_detection.py | 1 +
.../cloud/bigquery/example_bigquery_dataset.py | 1 +
.../google/cloud/bigquery/example_bigquery_dts.py | 1 +
.../cloud/bigquery/example_bigquery_operations.py | 1 +
.../example_bigquery_operations_location.py | 1 +
.../cloud/bigquery/example_bigquery_queries.py | 1 +
.../bigquery/example_bigquery_queries_async.py | 1 +
.../cloud/bigquery/example_bigquery_sensors.py | 1 +
.../cloud/bigquery/example_bigquery_tables.py | 1 +
.../cloud/bigquery/example_bigquery_to_bigquery.py | 1 +
.../cloud/bigquery/example_bigquery_to_gcs.py | 1 +
.../bigquery/example_bigquery_to_gcs_async.py | 1 +
.../cloud/bigquery/example_bigquery_to_mssql.py | 1 +
.../cloud/bigquery/example_bigquery_to_mysql.py | 1 +
.../cloud/bigquery/example_bigquery_to_postgres.py | 1 +
.../cloud/bigquery/example_bigquery_transfer.py | 1 +
.../google/cloud/bigtable/example_bigtable.py | 1 +
.../cloud/cloud_batch/example_cloud_batch.py | 1 +
.../cloud/cloud_build/example_cloud_build.py | 1 +
.../cloud_build/example_cloud_build_trigger.py | 1 +
.../example_cloud_memorystore_memcached.py | 1 +
.../example_cloud_memorystore_redis.py | 1 +
.../google/cloud/cloud_run/example_cloud_run.py | 1 +
.../google/cloud/cloud_sql/example_cloud_sql.py | 1 +
.../cloud_sql/example_cloud_sql_query_mysql.py | 1 +
.../cloud_sql/example_cloud_sql_query_postgres.py | 1 +
.../google/cloud/compute/example_compute_igm.py | 1 +
.../google/cloud/dataflow/example_dataflow_go.py | 1 +
.../cloud/dataflow/example_dataflow_native_java.py | 1 +
.../dataflow/example_dataflow_native_python.py | 1 +
.../example_dataflow_native_python_async.py | 1 +
.../google/cloud/dataflow/example_dataflow_sql.py | 1 +
.../dataflow/example_dataflow_streaming_python.py | 1 +
.../cloud/dataflow/example_dataflow_template.py | 1 +
.../google/cloud/dataform/example_dataform.py | 1 +
.../google/cloud/datafusion/example_datafusion.py | 1 +
.../cloud/datapipelines/example_datapipeline.py | 1 +
.../google/cloud/dataplex/example_dataplex.py | 1 +
.../google/cloud/dataplex/example_dataplex_dp.py | 1 +
.../google/cloud/dataplex/example_dataplex_dq.py | 1 +
.../google/cloud/dataprep/example_dataprep.py | 1 +
.../cloud/dataproc/example_dataproc_batch.py | 1 +
.../dataproc/example_dataproc_batch_deferrable.py | 1 +
.../dataproc/example_dataproc_batch_persistent.py | 1 +
...proc_cluster_create_existing_stopped_cluster.py | 1 +
.../example_dataproc_cluster_deferrable.py | 1 +
.../dataproc/example_dataproc_cluster_diagnose.py | 1 +
.../dataproc/example_dataproc_cluster_generator.py | 1 +
.../example_dataproc_cluster_start_stop.py | 1 +
.../dataproc/example_dataproc_cluster_update.py | 1 +
.../google/cloud/dataproc/example_dataproc_gke.py | 1 +
.../cloud/dataproc/example_dataproc_hadoop.py | 1 +
.../google/cloud/dataproc/example_dataproc_hive.py | 1 +
.../google/cloud/dataproc/example_dataproc_pig.py | 1 +
.../cloud/dataproc/example_dataproc_presto.py | 1 +
.../cloud/dataproc/example_dataproc_pyspark.py | 1 +
.../cloud/dataproc/example_dataproc_spark.py | 1 +
.../cloud/dataproc/example_dataproc_spark_async.py | 1 +
.../dataproc/example_dataproc_spark_deferrable.py | 1 +
.../cloud/dataproc/example_dataproc_spark_sql.py | 1 +
.../cloud/dataproc/example_dataproc_sparkr.py | 1 +
.../cloud/dataproc/example_dataproc_trino.py | 1 +
.../cloud/dataproc/example_dataproc_workflow.py | 1 +
.../example_dataproc_workflow_deferrable.py | 1 +
.../example_dataproc_metastore.py | 1 +
.../example_dataproc_metastore_backup.py | 1 +
...ple_dataproc_metastore_hive_partition_sensor.py | 1 +
.../cloud/datastore/example_datastore_commit.py | 1 +
.../cloud/datastore/example_datastore_query.py | 1 +
.../cloud/datastore/example_datastore_rollback.py | 1 +
.../google/cloud/gcs/example_firestore.py | 1 +
.../providers/google/cloud/gcs/example_gcs_acl.py | 1 +
.../google/cloud/gcs/example_gcs_copy_delete.py | 1 +
.../google/cloud/gcs/example_gcs_sensor.py | 1 +
.../google/cloud/gcs/example_gcs_to_bigquery.py | 1 +
.../cloud/gcs/example_gcs_to_bigquery_async.py | 1 +
.../google/cloud/gcs/example_gcs_to_gcs.py | 1 +
.../google/cloud/gcs/example_gcs_to_gdrive.py | 1 +
.../google/cloud/gcs/example_gcs_transform.py | 1 +
.../cloud/gcs/example_gcs_transform_timespan.py | 1 +
.../cloud/gcs/example_gcs_upload_download.py | 1 +
.../google/cloud/gcs/example_mysql_to_gcs.py | 1 +
.../google/cloud/gcs/example_sftp_to_gcs.py | 1 +
.../google/cloud/gcs/example_trino_to_gcs.py | 1 +
.../kubernetes_engine/example_kubernetes_engine.py | 1 +
.../example_kubernetes_engine_async.py | 1 +
.../example_kubernetes_engine_job.py | 1 +
.../example_kubernetes_engine_kueue.py | 1 +
.../example_kubernetes_engine_resource.py | 1 +
.../google/cloud/ml_engine/example_mlengine.py | 1 +
.../natural_language/example_natural_language.py | 1 +
.../google/cloud/pubsub/example_pubsub.py | 1 +
.../cloud/pubsub/example_pubsub_deferrable.py | 1 +
.../google/cloud/spanner/example_spanner.py | 1 +
.../cloud/sql_to_sheets/example_sql_to_sheets.py | 1 +
.../cloud/stackdriver/example_stackdriver.py | 1 +
.../example_cloud_storage_transfer_service_aws.py | 1 +
.../providers/google/cloud/tasks/example_queue.py | 1 +
.../providers/google/cloud/tasks/example_tasks.py | 1 +
.../google/cloud/transfers/example_gcs_to_sftp.py | 1 +
.../cloud/transfers/example_gdrive_to_local.py | 1 +
.../cloud/transfers/example_postgres_to_gcs.py | 1 +
.../google/cloud/translate/example_translate.py | 1 +
...ample_vertex_ai_auto_ml_forecasting_training.py | 1 +
.../example_vertex_ai_auto_ml_image_training.py | 1 +
.../example_vertex_ai_auto_ml_list_training.py | 1 +
.../example_vertex_ai_auto_ml_tabular_training.py | 1 +
.../example_vertex_ai_auto_ml_text_training.py | 1 +
.../example_vertex_ai_auto_ml_video_training.py | 1 +
.../example_vertex_ai_batch_prediction_job.py | 1 +
.../example_vertex_ai_custom_container.py | 1 +
.../vertex_ai/example_vertex_ai_custom_job.py | 1 +
.../example_vertex_ai_custom_job_python_package.py | 1 +
.../cloud/vertex_ai/example_vertex_ai_dataset.py | 1 +
.../cloud/vertex_ai/example_vertex_ai_endpoint.py | 1 +
.../example_vertex_ai_generative_model.py | 1 +
.../example_vertex_ai_hyperparameter_tuning_job.py | 1 +
.../example_vertex_ai_list_custom_jobs.py | 1 +
.../vertex_ai/example_vertex_ai_model_service.py | 1 +
.../vertex_ai/example_vertex_ai_pipeline_job.py | 1 +
.../providers/google/leveldb/example_leveldb.py | 1 +
.../google/marketing_platform/example_analytics.py | 1 +
.../marketing_platform/example_analytics_admin.py | 1 +
.../marketing_platform/example_campaign_manager.py | 1 +
.../marketing_platform/example_search_ads.py | 1 +
.../google/suite/example_local_to_drive.py | 1 +
tests/system/providers/http/example_http.py | 1 +
.../system/providers/jdbc/example_jdbc_queries.py | 1 +
.../azure/example_azure_batch_operator.py | 1 +
.../azure/example_azure_container_instances.py | 1 +
.../microsoft/azure/example_azure_cosmosdb.py | 1 +
.../microsoft/azure/example_wasb_sensors.py | 1 +
.../providers/microsoft/mssql/example_mssql.py | 1 +
.../providers/microsoft/winrm/example_winrm.py | 1 +
tests/system/providers/mysql/example_mysql.py | 1 +
tests/system/providers/neo4j/example_neo4j.py | 1 +
tests/system/providers/papermill/conftest.py | 6 +-
.../providers/papermill/example_papermill.py | 1 +
.../papermill/example_papermill_remote_verify.py | 1 +
.../papermill/example_papermill_verify.py | 1 +
.../providers/presto/example_gcs_to_presto.py | 1 +
.../providers/redis/example_redis_publish.py | 1 +
.../system/providers/samba/example_gcs_to_samba.py | 1 +
.../system/providers/slack/example_sql_to_slack.py | 1 +
.../slack/example_sql_to_slack_webhook.py | 1 +
.../snowflake/example_copy_into_snowflake.py | 1 +
.../providers/snowflake/example_snowflake.py | 1 +
tests/system/providers/sqlite/example_sqlite.py | 1 +
tests/system/providers/tableau/example_tableau.py | 1 +
.../system/providers/telegram/example_telegram.py | 1 +
.../providers/teradata/example_ssl_teradata.py | 1 +
.../system/providers/teradata/example_teradata.py | 1 +
.../example_teradata_to_teradata_transfer.py | 1 +
.../system/providers/trino/example_gcs_to_trino.py | 1 +
tests/system/providers/trino/example_trino.py | 1 +
tests/test_utils/get_all_tests.py | 1 +
tests/test_utils/remote_user_api_auth_backend.py | 1 +
tests/utils/log/test_json_formatter.py | 1 +
tests/utils/test_orm_event_handlers.py | 1 +
tests/utils/test_task_group.py | 36 ++---
784 files changed, 1023 insertions(+), 658 deletions(-)
