This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a change to branch vincbeck/fab_remove_sqla_limit
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 3b5be061149 Remove SQLA 1 limit in Fab provider
add 687f062f2d1 Enable PT006 rule to microsoft Provider test(hooks)
(#57932)
add 518be181956 Enable PT006 rule to ssh Provider test (#57929)
add 63587d2cdad Enable PT006 rule to microsoft Provider test(log,sensors)
(#57927)
add 5717cc82a54 Enable PT006 rule to samba Provider test(transfers, hooks)
(#57926)
add d7722e42027 Enable PT006 rule to microsoft Provider test(transfers)
(#57925)
add 5616b19966b PT006 modify standard (operator) (#58020)
add dc5c6b2fd8b Enable PT006 rule to standard Provider test(decorator,
hook) 8 files (#58019)
add ba9b8946d53 Enable PT006 rule to 6 files in providers (edge3,git)
(#58018)
add 138eddfa8bc modify all remaining files related to airflow-core (#58015)
add 1b39eaf6991 Enable PT006 rule to airflow-core tests (auth, common,
always, integration) (#58014)
add 682a50e80f6 modify route/public (#58012)
add ee6dc199e16 Enable PT006 rule to airflow-core tests (route/ui,
execution_api) (#58010)
add 2e909034354 Enable PT006 rule to airflow-core tests (cli) (#58007)
add 571e03f2a53 Enable PT006 rule to 23 files in providers (all remaining
files related to amazon) (#58005)
add c09e3f92d31 Enable PT006 rule to 23 files in providers (amazon ->
hooks, links, log, queues) (#58003)
add 468d2f25d46 Fix logout in Fab and Keycloak auth managers (#57992)
add 76d71783839 Stubbing missing tests for task sdk integration testing
for xcoms (#58031)
add d9a3b2c1d0d Stubbing missing tests for task sdk integration testing
for variables (#58030)
add e6d650bac62 Stubbing missing tests for task sdk integration testing
for connection (#58029)
add d1a4c0c056a Stubbing missing tests for task sdk integration testing
for dagruns (#58036)
add 816d3dc233a Docs: Add note on running prek inside Breeze (#58039)
add db0260d00be Update Arabic translation 2025-11-07 (#58042)
add 58a2abd912b Add number of queries guard for ui team (#57980)
add 56ddebe108c Add number of queries guard for ui grid (#57977)
add 7594818de51 fix typos in comments within triggerer_job_runner.py
(#58013)
add f5789979b9c Update Hebrew translation 2025-11-07 (#58041)
add e4f9fef36e8 Add number of queries guard for ui calendar (#58044)
add 63a8f549f2a Enable PT006 rule to 14 files in providers
(databricks,dbt,docker) (#57994)
add 4d7c077e450 Enable PT006 rule to sftp Provider test (#57924)
add a533af5f788 Enable PT006 rule to microsoft Provider test(operators)
(#57928)
add 139a7846e85 Enable PT006 rule to postgres Provider test (#57934)
add 3a783ecf4c0 Enable PT006 rule to microsoft Provider
test(azure,mssql,psrp) (#57936)
add 08e09a25711 Enable PT006 rule to mysql Provider test (#57937)
add 884cbeb3a0f Enable PT006 rule to celery Provider test (#57938)
add c684cb67a3e Enable PT006 rule to neo4j Provider test (#57939)
add 5b9436bc419 Enable PT006 rule to openlineage Provider test (#57940)
add 5bb13eb8fcf Enable PT006 rule to oracle Provider test (#57941)
add ce90b46a921 Enable PT006 rule to google Provider test (operators
part2) (#57944)
add c3b19ac8cf5 Enable PT006 rule to google Provider test
(log,openlineage,common,utils) (#57947)
add 93f93035b5e Enable PT006 rule to airflow-core tests (core,
dag_processing) (#57948)
add 36b4545500a Enable PT006 rule to airflow-core tests (models) (#57949)
add ec669b977c6 Enable PT006 rule to google Provider test (triggers)
(#57950)
add c54baeadd58 Enable PT006 rule to airflow-core tests (models) (#57951)
add 094756a160f Enable PT006 rule to google Provider test (triggers)
(#57953)
add 5891dea5a8f Enable PT006 rule to slack Provider test (#57963)
add 62e896bc908 Enable PT006 rule to 19 files in providers (airbyte,
alibaba, atlassian, papermill, presto, redis, singularity, sqlite, tableau,
vertica, weaviate, elasticsearch, exasol) (#57986)
add a0138b4813a Enable PT006 rule to 19 files in providers (cncf,common)
(#57995)
add 92f35b14019 Enable PT006 rule to 13 files in providers (apache)
(#57998)
add 2c12bff3edd Enable PT006 rule to standard Provider test(ssensor,
trigge, util) 9 files (#58022)
add 7a69adf43c6 Add number of queries guard for ui next_run_assets (#58052)
add 2abece069ac fix MyPy type errors in datamodels/hitl.py (#57808)
add 3ba3c784040 Remove global from serialization (#57703)
add fc05e4bbe57 Enable PT006 rule to airflow-core tests (route/public)
(#58011)
add 8d0131c58fe Fix MyPy type errors in
api_fastapi(security.py),airflow/models(dag_version.py,hitl.py),mark_tasks.py
(#58054)
add 061e27e07b6 Remove SQLA 1 limit in Fab provider
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 (3b5be061149)
\
N -- N -- N refs/heads/vincbeck/fab_remove_sqla_limit
(061e27e07b6)
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:
airflow-core/src/airflow/api/common/mark_tasks.py | 6 +-
.../src/airflow/api_fastapi/core_api/security.py | 2 +-
.../api_fastapi/execution_api/datamodels/hitl.py | 5 +-
.../src/airflow/jobs/triggerer_job_runner.py | 6 +-
airflow-core/src/airflow/models/dag_version.py | 2 +
airflow-core/src/airflow/models/hitl.py | 2 +-
.../airflow/serialization/serialized_objects.py | 15 ++--
.../airflow/ui/public/i18n/locales/ar/common.json | 7 ++
.../ui/public/i18n/locales/ar/components.json | 12 ++++
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 2 +
.../airflow/ui/public/i18n/locales/ar/hitl.json | 5 ++
.../airflow/ui/public/i18n/locales/he/common.json | 7 ++
.../ui/public/i18n/locales/he/components.json | 6 ++
.../src/airflow/ui/public/i18n/locales/he/dag.json | 2 +
.../airflow/ui/public/i18n/locales/he/hitl.json | 5 ++
.../cli/commands/test_celery_command.py | 2 +-
.../tests/integration/security/test_kerberos.py | 2 +-
airflow-core/tests/unit/always/test_connection.py | 12 ++--
.../tests/unit/always/test_providers_manager.py | 2 +-
.../tests/unit/always/test_secrets_backends.py | 2 +-
.../unit/always/test_secrets_local_filesystem.py | 30 ++++----
.../managers/simple/test_simple_auth_manager.py | 16 ++---
.../auth/managers/test_base_auth_manager.py | 18 ++---
.../tests/unit/api_fastapi/auth/test_tokens.py | 2 +-
.../unit/api_fastapi/common/test_exceptions.py | 4 +-
.../core_api/routes/public/test_assets.py | 20 +++---
.../core_api/routes/public/test_auth.py | 2 +-
.../core_api/routes/public/test_backfills.py | 10 +--
.../core_api/routes/public/test_config.py | 8 +--
.../core_api/routes/public/test_connections.py | 16 ++---
.../core_api/routes/public/test_dag_run.py | 40 +++++------
.../core_api/routes/public/test_dag_stats.py | 2 +-
.../core_api/routes/public/test_dag_tags.py | 2 +-
.../core_api/routes/public/test_dag_versions.py | 10 +--
.../core_api/routes/public/test_dag_warning.py | 2 +-
.../core_api/routes/public/test_dags.py | 45 +++++++++---
.../core_api/routes/public/test_event_logs.py | 4 +-
.../core_api/routes/public/test_extra_links.py | 2 +-
.../core_api/routes/public/test_hitl.py | 4 +-
.../core_api/routes/public/test_import_error.py | 6 +-
.../api_fastapi/core_api/routes/public/test_job.py | 2 +-
.../api_fastapi/core_api/routes/public/test_log.py | 6 +-
.../core_api/routes/public/test_plugins.py | 2 +-
.../core_api/routes/public/test_pools.py | 16 +++--
.../core_api/routes/public/test_providers.py | 2 +-
.../core_api/routes/public/test_task_instances.py | 64 ++++++++---------
.../core_api/routes/public/test_variables.py | 12 ++--
.../core_api/routes/public/test_xcom.py | 12 ++--
.../api_fastapi/core_api/routes/ui/test_assets.py | 4 +-
.../core_api/routes/ui/test_backfills.py | 2 +-
.../core_api/routes/ui/test_calendar.py | 11 +--
.../api_fastapi/core_api/routes/ui/test_dags.py | 6 +-
.../core_api/routes/ui/test_dashboard.py | 2 +-
.../core_api/routes/ui/test_dependencies.py | 2 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 82 ++++++++++++++--------
.../core_api/routes/ui/test_structure.py | 4 +-
.../api_fastapi/core_api/routes/ui/test_teams.py | 4 +-
.../services/public/test_task_instances.py | 8 ++-
.../unit/api_fastapi/core_api/test_security.py | 6 +-
.../versions/head/test_asset_events.py | 14 ++--
.../execution_api/versions/head/test_hitl.py | 2 +-
.../versions/head/test_task_instances.py | 27 ++-----
.../execution_api/versions/head/test_variables.py | 10 +--
.../execution_api/versions/head/test_xcoms.py | 6 +-
.../versions/v2025_04_28/test_task_instances.py | 2 +-
.../versions/v2025_04_28/test_xcom.py | 2 +-
airflow-core/tests/unit/api_fastapi/test_app.py | 2 +-
airflow-core/tests/unit/assets/test_evaluation.py | 8 +--
.../tests/unit/callbacks/test_callback_requests.py | 4 +-
airflow-core/tests/unit/charts/log_groomer.py | 4 +-
.../unit/cli/commands/test_api_server_command.py | 4 +-
.../unit/cli/commands/test_backfill_command.py | 2 +-
.../tests/unit/cli/commands/test_config_command.py | 4 +-
.../unit/cli/commands/test_connection_command.py | 4 +-
.../tests/unit/cli/commands/test_db_command.py | 36 +++++-----
.../tests/unit/cli/commands/test_info_command.py | 2 +-
.../unit/cli/commands/test_scheduler_command.py | 2 +-
.../unit/cli/commands/test_variable_command.py | 2 +-
airflow-core/tests/unit/cli/test_cli_parser.py | 2 +-
airflow-core/tests/unit/core/test_configuration.py | 8 +--
.../tests/unit/core/test_example_dags_system.py | 2 +-
airflow-core/tests/unit/core/test_settings.py | 2 +-
airflow-core/tests/unit/core/test_stats.py | 6 +-
.../tests/unit/dag_processing/bundles/test_base.py | 4 +-
.../bundles/test_dag_bundle_manager.py | 2 +-
.../tests/unit/dag_processing/test_collection.py | 6 +-
.../tests/unit/dag_processing/test_dagbag.py | 4 +-
.../tests/unit/dag_processing/test_manager.py | 8 +--
.../tests/unit/dag_processing/test_processor.py | 8 +--
airflow-core/tests/unit/models/test_asset.py | 2 +-
airflow-core/tests/unit/models/test_backfill.py | 2 +-
airflow-core/tests/unit/models/test_callback.py | 4 +-
airflow-core/tests/unit/models/test_cleartasks.py | 6 +-
airflow-core/tests/unit/models/test_connection.py | 22 ++++--
airflow-core/tests/unit/models/test_dag.py | 24 +++----
airflow-core/tests/unit/models/test_dagrun.py | 16 ++---
airflow-core/tests/unit/models/test_deadline.py | 6 +-
.../tests/unit/models/test_mappedoperator.py | 50 ++++++-------
.../tests/unit/models/test_renderedtifields.py | 6 +-
.../tests/unit/models/test_serialized_dag.py | 2 +-
.../tests/unit/models/test_taskinstance.py | 27 ++++---
airflow-core/tests/unit/models/test_trigger.py | 2 +-
airflow-core/tests/unit/models/test_variable.py | 2 +-
airflow-core/tests/unit/models/test_xcom.py | 4 +-
airflow-core/tests/unit/models/test_xcom_arg.py | 2 +-
.../unit/serialization/test_serialized_objects.py | 2 +
dev/breeze/doc/03_developer_tasks.rst | 11 +++
.../tests/unit/airbyte/triggers/test_airbyte.py | 10 +--
.../unit/alibaba/cloud/links/test_maxcompute.py | 2 +-
.../alibaba/cloud/log/test_oss_task_handler.py | 2 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 4 +-
.../aws/auth_manager/test_aws_auth_manager.py | 22 +++---
.../aws/executors/batch/test_batch_executor.py | 2 +-
.../unit/amazon/aws/executors/batch/test_utils.py | 2 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 4 +-
.../utils/test_exponential_backoff_retry.py | 4 +-
.../tests/unit/amazon/aws/hooks/test_athena_sql.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 20 +++---
.../unit/amazon/aws/hooks/test_batch_client.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_bedrock.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_datasync.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_dynamodb.py | 4 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ecr.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_eks.py | 6 +-
.../amazon/aws/hooks/test_kinesis_analytics.py | 2 +-
.../unit/amazon/aws/hooks/test_lambda_function.py | 4 +-
.../tests/unit/amazon/aws/hooks/test_logs.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_quicksight.py | 12 ++--
.../unit/amazon/aws/hooks/test_redshift_data.py | 8 +--
.../unit/amazon/aws/hooks/test_redshift_sql.py | 6 +-
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 16 ++---
.../amazon/tests/unit/amazon/aws/hooks/test_ssm.py | 2 +-
.../tests/unit/amazon/aws/links/test_base_aws.py | 2 +-
.../amazon/tests/unit/amazon/aws/links/test_emr.py | 4 +-
.../unit/amazon/aws/links/test_step_function.py | 4 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 4 +-
.../unit/amazon/aws/log/test_s3_task_handler.py | 2 +-
.../tests/unit/amazon/aws/queues/test_sqs.py | 2 +-
.../amazon/aws/secrets/test_secrets_manager.py | 6 +-
.../amazon/aws/secrets/test_systems_manager.py | 6 +-
.../tests/unit/amazon/aws/sensors/test_batch.py | 2 +-
.../unit/amazon/aws/sensors/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ecs.py | 16 ++---
.../aws/sensors/test_emr_serverless_application.py | 2 +-
.../amazon/aws/sensors/test_emr_serverless_job.py | 2 +-
.../amazon/aws/sensors/test_lambda_function.py | 2 +-
.../aws/sensors/test_opensearch_serverless.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_s3.py | 8 +--
.../unit/amazon/aws/system/utils/test_helpers.py | 4 +-
.../amazon/aws/transfers/test_redshift_to_s3.py | 20 ++++--
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 16 ++---
.../aws/triggers/test_opensearch_serverless.py | 2 +-
.../unit/amazon/aws/triggers/test_redshift_data.py | 4 +-
.../amazon/aws/utils/test_connection_wrapper.py | 10 +--
.../unit/amazon/aws/utils/test_eks_get_token.py | 2 +-
.../tests/unit/amazon/aws/utils/test_waiter.py | 2 +-
.../beam/tests/unit/apache/beam/hooks/test_beam.py | 8 +--
.../tests/unit/apache/beam/operators/test_beam.py | 2 +-
.../tests/unit/apache/drill/hooks/test_drill.py | 4 +-
.../tests/unit/apache/druid/hooks/test_druid.py | 2 +-
.../tests/unit/apache/hdfs/hooks/test_webhdfs.py | 2 +-
.../unit/apache/hdfs/log/test_hdfs_task_handler.py | 2 +-
.../hive/tests/unit/apache/hive/hooks/test_hive.py | 6 +-
.../unit/apache/impala/hooks/test_impala_sql.py | 4 +-
.../unit/apache/kafka/operators/test_consume.py | 6 +-
.../tests/unit/apache/kafka/queues/test_kafka.py | 8 +--
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 2 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 2 +-
.../unit/apache/tinkerpop/hooks/test_gremlin.py | 6 +-
.../tests/unit/atlassian/jira/hooks/test_jira.py | 4 +-
.../unit/celery/executors/test_celery_executor.py | 2 +-
.../executors/test_celery_kubernetes_executor.py | 4 +-
.../kubernetes/decorators/test_kubernetes_cmd.py | 4 +-
.../decorators/test_kubernetes_commons.py | 2 +-
.../executors/test_kubernetes_executor.py | 10 +--
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 28 ++++----
.../kubernetes/log_handlers/test_log_handlers.py | 2 +-
.../unit/cncf/kubernetes/operators/test_job.py | 10 +--
.../unit/cncf/kubernetes/operators/test_pod.py | 30 ++++----
.../kubernetes/operators/test_spark_kubernetes.py | 6 +-
.../kubernetes/test_kubernetes_helper_functions.py | 6 +-
.../unit/cncf/kubernetes/test_pod_generator.py | 10 +--
.../unit/cncf/kubernetes/triggers/test_pod.py | 6 +-
.../unit/cncf/kubernetes/utils/test_container.py | 6 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 24 +++++--
.../tests/unit/common/compat/test__compat_utils.py | 8 +--
.../io/tests/unit/common/io/xcom/test_backend.py | 2 +-
.../sql/tests/unit/common/sql/hooks/test_sql.py | 14 +++-
.../tests/unit/common/sql/hooks/test_sqlparse.py | 2 +-
.../tests/unit/common/sql/operators/test_sql.py | 4 +-
.../unit/common/sql/operators/test_sql_execute.py | 6 +-
.../tests/unit/databricks/hooks/test_databricks.py | 2 +-
.../unit/databricks/hooks/test_databricks_base.py | 4 +-
.../unit/databricks/hooks/test_databricks_sql.py | 19 +++--
.../databricks/operators/test_databricks_sql.py | 4 +-
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 72 +++++++++----------
.../tests/unit/dbt/cloud/operators/test_dbt.py | 32 ++++-----
.../cloud/tests/unit/dbt/cloud/sensors/test_dbt.py | 2 +-
.../tests/unit/dbt/cloud/triggers/test_dbt.py | 12 ++--
.../tests/unit/dbt/cloud/utils/test_openlineage.py | 2 +-
.../tests/unit/docker/decorators/test_docker.py | 2 +-
.../docker/tests/unit/docker/hooks/test_docker.py | 6 +-
.../tests/unit/docker/operators/test_docker.py | 6 +-
.../unit/docker/operators/test_docker_swarm.py | 4 +-
.../docker/tests/unit/docker/test_exceptions.py | 2 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 6 +-
.../unit/edge3/executors/test_edge_executor.py | 2 +-
.../edge3/plugins/test_edge_executor_plugin.py | 2 +-
.../unit/edge3/worker_api/routes/test_worker.py | 4 +-
.../unit/elasticsearch/log/test_es_task_handler.py | 6 +-
.../exasol/tests/unit/exasol/hooks/test_exasol.py | 4 +-
.../exasol/tests/unit/exasol/hooks/test_sql.py | 12 +++-
.../tests/unit/exasol/operators/test_exasol_sql.py | 2 +-
.../openapi/v2-fab-auth-manager-generated.yaml | 13 ++++
.../fab/auth_manager/api_fastapi/routes/login.py | 27 +++++++
.../providers/fab/auth_manager/fab_auth_manager.py | 2 +-
.../unit/fab/auth_manager/api_fastapi/conftest.py | 2 +-
.../auth_manager/api_fastapi/routes/test_login.py | 9 +++
.../unit/fab/auth_manager/test_fab_auth_manager.py | 2 +-
providers/git/tests/unit/git/bundles/test_git.py | 10 +--
providers/git/tests/unit/git/hooks/test_git.py | 2 +-
.../unit/google/cloud/log/test_gcs_task_handler.py | 2 +-
.../unit/google/cloud/openlineage/test_utils.py | 8 +--
.../unit/google/cloud/operators/test_datafusion.py | 2 +-
.../unit/google/cloud/operators/test_dataprep.py | 4 +-
.../unit/google/cloud/operators/test_functions.py | 12 ++--
.../cloud/operators/test_kubernetes_engine.py | 13 +++-
.../unit/google/cloud/operators/test_pubsub.py | 4 +-
.../unit/google/cloud/operators/test_spanner.py | 14 ++--
.../google/cloud/operators/test_text_to_speech.py | 2 +-
.../cloud/transfers/test_bigquery_to_postgres.py | 3 +-
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 10 ++-
.../google/cloud/transfers/test_gcs_to_sftp.py | 30 ++++++--
.../google/cloud/transfers/test_mssql_to_gcs.py | 7 +-
.../google/cloud/transfers/test_mysql_to_gcs.py | 4 +-
.../google/cloud/transfers/test_oracle_to_gcs.py | 2 +-
.../google/cloud/transfers/test_postgres_to_gcs.py | 4 +-
.../unit/google/cloud/transfers/test_s3_to_gcs.py | 4 +-
.../google/cloud/transfers/test_sftp_to_gcs.py | 2 +-
.../google/cloud/transfers/test_trino_to_gcs.py | 2 +-
.../google/cloud/triggers/test_bigquery_dts.py | 2 +-
.../test_cloud_storage_transfer_service.py | 8 +--
.../unit/google/cloud/triggers/test_dataflow.py | 14 ++--
.../tests/unit/google/cloud/triggers/test_gcs.py | 12 ++--
.../cloud/triggers/test_kubernetes_engine.py | 2 +-
.../unit/google/cloud/triggers/test_vertex_ai.py | 2 +-
.../cloud/utils/test_credentials_provider.py | 4 +-
.../tests/unit/google/cloud/utils/test_dataform.py | 2 +-
.../unit/google/cloud/utils/test_datafusion.py | 2 +-
.../tests/unit/google/cloud/utils/test_dataproc.py | 2 +-
.../tests/unit/google/common/test_deprecated.py | 10 +--
.../keycloak/auth_manager/keycloak_auth_manager.py | 4 ++
.../v2-keycloak-auth-manager-generated.yaml | 33 +++++++++
.../keycloak/auth_manager/routes/login.py | 38 ++++++++--
.../unit/keycloak/auth_manager/routes/conftest.py | 27 ++++++-
.../keycloak/auth_manager/routes/test_login.py | 38 ++++++++++
.../auth_manager/test_keycloak_auth_manager.py | 4 ++
.../tests/unit/microsoft/azure/hooks/test_adx.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_asb.py | 6 +-
.../unit/microsoft/azure/hooks/test_powerbi.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_wasb.py | 4 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 2 +-
.../unit/microsoft/azure/operators/test_asb.py | 6 +-
.../microsoft/azure/operators/test_data_factory.py | 4 +-
.../unit/microsoft/azure/operators/test_synapse.py | 2 +-
.../microsoft/azure/sensors/test_data_factory.py | 2 +-
.../azure/tests/unit/microsoft/azure/test_utils.py | 4 +-
.../microsoft/azure/transfers/test_s3_to_wasb.py | 6 +-
.../microsoft/azure/triggers/test_data_factory.py | 4 +-
.../tests/unit/microsoft/mssql/hooks/test_mssql.py | 2 +-
.../unit/microsoft/psrp/operators/test_psrp.py | 2 +-
.../mysql/tests/unit/mysql/assets/test_mysql.py | 2 +-
.../mysql/tests/unit/mysql/hooks/test_mysql.py | 2 +-
.../neo4j/tests/unit/neo4j/hooks/test_neo4j.py | 4 +-
.../tests/unit/openlineage/extractors/test_base.py | 2 +-
.../tests/unit/openlineage/operators/test_empty.py | 2 +-
.../tests/unit/openlineage/plugins/test_adapter.py | 2 +-
.../unit/openlineage/plugins/test_listener.py | 10 +--
.../unit/openlineage/plugins/test_openlineage.py | 2 +-
.../tests/unit/openlineage/utils/test_spark.py | 10 +--
.../tests/unit/openlineage/utils/test_sql.py | 2 +-
.../tests/unit/openlineage/utils/test_utils.py | 4 +-
.../oracle/tests/unit/oracle/hooks/test_oracle.py | 2 +-
.../unit/papermill/operators/test_papermill.py | 4 +-
.../tests/unit/postgres/assets/test_postgres.py | 2 +-
.../tests/unit/postgres/hooks/test_postgres.py | 8 +--
.../presto/tests/unit/presto/hooks/test_presto.py | 2 +-
.../tests/unit/presto/hooks/test_presto_sql.py | 11 ++-
.../redis/tests/unit/redis/queues/test_redis.py | 2 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 2 +-
.../unit/samba/transfers/test_gcs_to_samba.py | 24 +++++--
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 6 +-
.../sftp/tests/unit/sftp/operators/test_sftp.py | 4 +-
.../sftp/tests/unit/sftp/sensors/test_sftp.py | 4 +-
.../unit/singularity/operators/test_singularity.py | 4 +-
.../slack/tests/unit/slack/hooks/test_slack.py | 6 +-
.../tests/unit/slack/hooks/test_slack_webhook.py | 6 +-
.../tests/unit/slack/notifications/test_slack.py | 2 +-
.../unit/slack/notifications/test_slack_webhook.py | 2 +-
.../slack/tests/unit/slack/operators/test_slack.py | 2 +-
.../unit/slack/operators/test_slack_webhook.py | 6 +-
.../unit/slack/transfers/test_sql_to_slack.py | 4 +-
.../slack/transfers/test_sql_to_slack_webhook.py | 4 +-
.../slack/tests/unit/slack/utils/test_utils.py | 4 +-
.../sqlite/tests/unit/sqlite/hooks/test_sqlite.py | 2 +-
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 2 +-
providers/ssh/tests/unit/ssh/operators/test_ssh.py | 6 +-
.../airflow/providers/standard/triggers/hitl.py | 12 ++--
.../tests/unit/standard/decorators/test_bash.py | 14 ++--
.../decorators/test_branch_external_python.py | 2 +-
.../unit/standard/decorators/test_branch_python.py | 2 +-
.../standard/decorators/test_branch_virtualenv.py | 2 +-
.../tests/unit/standard/decorators/test_python.py | 2 +-
.../standard/decorators/test_python_virtualenv.py | 6 +-
.../unit/standard/decorators/test_short_circuit.py | 4 +-
.../tests/unit/standard/hooks/test_subprocess.py | 4 +-
.../tests/unit/standard/operators/test_bash.py | 6 +-
.../tests/unit/standard/operators/test_datetime.py | 6 +-
.../tests/unit/standard/operators/test_hitl.py | 10 +--
.../tests/unit/standard/operators/test_python.py | 20 +++---
.../unit/standard/operators/test_trigger_dagrun.py | 6 +-
.../tests/unit/standard/operators/test_weekday.py | 2 +-
.../tests/unit/standard/sensors/test_date_time.py | 6 +-
.../standard/sensors/test_external_task_sensor.py | 10 +--
.../tests/unit/standard/sensors/test_time.py | 4 +-
.../unit/standard/triggers/test_external_task.py | 11 ++-
.../tests/unit/standard/triggers/test_temporal.py | 2 +-
.../unit/standard/utils/test_python_virtualenv.py | 2 +-
.../unit/standard/utils/test_sensor_helper.py | 2 +-
.../tests/unit/standard/utils/test_skipmixin.py | 4 +-
.../tests/unit/standard/utils/test_weekday.py | 4 +-
.../tests/unit/tableau/hooks/test_tableau.py | 2 +-
.../tests/unit/vertica/hooks/test_vertica_sql.py | 2 +-
.../tests/unit/weaviate/hooks/test_weaviate.py | 6 +-
.../task_sdk_tests/test_connection_operations.py | 14 ++++
.../task_sdk_tests/test_dag_run_operations.py | 50 +++++++++++++
.../task_sdk_tests/test_variable_operations.py | 26 +++++++
.../tests/task_sdk_tests/test_xcom_operations.py | 74 +++++++++++++++++++
339 files changed, 1608 insertions(+), 1016 deletions(-)
