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 17dec440de4 Set `SQLALCHEMY_ENGINE_DEBUG`
omit c2a3e0498fb Remove SQLA 1 limit in Fab provider
add bfb99f5f524 Add backcompat for exceptions in providers (#58727)
add 38db2defa23 Show asset extra in asset list (#59195)
add 92d2f87572a Add toggle functionality to Dags state filters (#59089)
add 217fc5f59a6 Remove global from providers amazon tests (#59178)
add 85b65eb3961 Fix misleading error message when GitHook creation fails
(#59084)
add 0beaf2d3cca Adding retries and pool to Weaviate dags to handle
connection latency issues (#59198)
add a59d2ecdc39 chore: use OL macros instead of building OL ids from
scratch (#59197)
add dd31202e8c4 Convert the exclusion on urllib3 to != for 2.6.0 (#59203)
add 68275ced21c Remove tags from AWS system tests (#59206)
add a178d00aa5e Remove team ID and use team name as PK (#59109)
add b1e42d1f9be Remove SQLA 1 limit in Fab provider
add f3cc8f8eb37 Set `SQLALCHEMY_ENGINE_DEBUG`
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 (17dec440de4)
\
N -- N -- N refs/heads/vincbeck/fab_remove_sqla_limit
(f3cc8f8eb37)
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/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 573 ++++++++++-----------
airflow-core/docs/migrations-ref.rst | 5 +-
.../api_fastapi/auth/managers/base_auth_manager.py | 13 +-
.../api_fastapi/core_api/datamodels/ui/teams.py | 3 -
.../api_fastapi/core_api/datamodels/variables.py | 5 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 11 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 13 +-
.../api_fastapi/core_api/routes/ui/teams.py | 2 +-
.../src/airflow/cli/commands/team_command.py | 13 +-
.../src/airflow/dag_processing/bundles/manager.py | 13 +-
.../versions/0094_3_1_0_remove_team_id.py | 148 ++++++
airflow-core/src/airflow/models/connection.py | 24 +-
airflow-core/src/airflow/models/pool.py | 12 +-
airflow-core/src/airflow/models/team.py | 31 +-
airflow-core/src/airflow/models/variable.py | 42 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 2 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 2 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 2 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 2 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 22 +-
.../ui/openapi-gen/requests/services.gen.ts | 2 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 7 +-
.../airflow/ui/public/i18n/locales/en/assets.json | 1 +
.../airflow/ui/public/i18n/locales/en/browse.json | 4 -
.../airflow/ui/public/i18n/locales/en/common.json | 2 +
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 43 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 14 +-
.../src/airflow/ui/src/pages/Events/Events.tsx | 6 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 4 +-
airflow-core/src/airflow/utils/db.py | 2 +-
.../auth/managers/test_base_auth_manager.py | 6 +-
.../unit/api_fastapi/common/test_exceptions.py | 12 +-
.../core_api/routes/public/test_variables.py | 45 +-
.../api_fastapi/core_api/routes/ui/test_teams.py | 5 -
.../tests/unit/cli/commands/test_team_command.py | 24 +-
.../bundles/test_dag_bundle_manager.py | 47 ++
airflow-core/tests/unit/models/test_connection.py | 7 +-
airflow-core/tests/unit/models/test_pool.py | 9 +-
airflow-core/tests/unit/models/test_team.py | 50 +-
airflow-core/tests/unit/models/test_variable.py | 15 +-
.../src/airflowctl/api/datamodels/generated.py | 8 +-
clients/python/pyproject.toml | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 3 +-
kubernetes-tests/pyproject.toml | 2 +-
providers/airbyte/pyproject.toml | 2 +-
.../src/airflow/providers/airbyte/hooks/airbyte.py | 3 +-
.../airflow/providers/airbyte/operators/airbyte.py | 3 +-
.../airflow/providers/airbyte/sensors/airbyte.py | 3 +-
.../tests/unit/airbyte/hooks/test_airbyte.py | 2 +-
.../tests/unit/airbyte/sensors/test_airbyte.py | 2 +-
providers/alibaba/pyproject.toml | 2 +-
.../alibaba/cloud/hooks/analyticdb_spark.py | 3 +-
.../airflow/providers/alibaba/cloud/hooks/oss.py | 3 +-
.../alibaba/cloud/operators/analyticdb_spark.py | 3 +-
.../providers/alibaba/cloud/sensors/oss_key.py | 4 +-
.../cloud/operators/test_analyticdb_spark.py | 2 +-
.../unit/alibaba/cloud/sensors/test_oss_key.py | 2 +-
.../amazon/aws/auth_manager/avp/facade.py | 2 +-
.../src/airflow/providers/amazon/aws/bundles/s3.py | 2 +-
.../src/airflow/providers/amazon/aws/exceptions.py | 2 +-
.../aws/executors/aws_lambda/lambda_executor.py | 3 +-
.../amazon/aws/executors/batch/batch_executor.py | 3 +-
.../amazon/aws/executors/ecs/ecs_executor.py | 3 +-
.../airflow/providers/amazon/aws/hooks/athena.py | 2 +-
.../providers/amazon/aws/hooks/athena_sql.py | 2 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 8 +-
.../providers/amazon/aws/hooks/batch_client.py | 2 +-
.../providers/amazon/aws/hooks/batch_waiters.py | 2 +-
.../airflow/providers/amazon/aws/hooks/chime.py | 2 +-
.../providers/amazon/aws/hooks/comprehend.py | 2 +-
.../airflow/providers/amazon/aws/hooks/datasync.py | 4 +-
.../airflow/providers/amazon/aws/hooks/dynamodb.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/ec2.py | 2 +-
.../aws/hooks/elasticache_replication_group.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/emr.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/glue.py | 3 +-
.../providers/amazon/aws/hooks/glue_catalog.py | 2 +-
.../providers/amazon/aws/hooks/quicksight.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/rds.py | 2 +-
.../providers/amazon/aws/hooks/redshift_sql.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 3 +-
.../providers/amazon/aws/hooks/sagemaker.py | 2 +-
.../amazon/aws/hooks/sagemaker_unified_studio.py | 3 +-
.../src/airflow/providers/amazon/aws/links/emr.py | 2 +-
.../providers/amazon/aws/operators/appflow.py | 2 +-
.../providers/amazon/aws/operators/athena.py | 2 +-
.../providers/amazon/aws/operators/batch.py | 2 +-
.../providers/amazon/aws/operators/bedrock.py | 2 +-
.../providers/amazon/aws/operators/comprehend.py | 2 +-
.../providers/amazon/aws/operators/datasync.py | 3 +-
.../airflow/providers/amazon/aws/operators/dms.py | 2 +-
.../airflow/providers/amazon/aws/operators/ec2.py | 2 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 2 +-
.../airflow/providers/amazon/aws/operators/eks.py | 3 +-
.../airflow/providers/amazon/aws/operators/emr.py | 3 +-
.../providers/amazon/aws/operators/eventbridge.py | 2 +-
.../airflow/providers/amazon/aws/operators/glue.py | 2 +-
.../providers/amazon/aws/operators/glue_crawler.py | 2 +-
.../amazon/aws/operators/glue_databrew.py | 2 +-
.../amazon/aws/operators/kinesis_analytics.py | 2 +-
.../amazon/aws/operators/lambda_function.py | 2 +-
.../airflow/providers/amazon/aws/operators/mwaa.py | 2 +-
.../providers/amazon/aws/operators/neptune.py | 2 +-
.../airflow/providers/amazon/aws/operators/rds.py | 2 +-
.../amazon/aws/operators/redshift_cluster.py | 2 +-
.../amazon/aws/operators/redshift_data.py | 2 +-
.../airflow/providers/amazon/aws/operators/s3.py | 2 +-
.../providers/amazon/aws/operators/sagemaker.py | 2 +-
.../aws/operators/sagemaker_unified_studio.py | 3 +-
.../amazon/aws/operators/step_function.py | 2 +-
.../airflow/providers/amazon/aws/sensors/athena.py | 2 +-
.../airflow/providers/amazon/aws/sensors/batch.py | 2 +-
.../providers/amazon/aws/sensors/bedrock.py | 2 +-
.../providers/amazon/aws/sensors/comprehend.py | 2 +-
.../airflow/providers/amazon/aws/sensors/dms.py | 2 +-
.../airflow/providers/amazon/aws/sensors/ec2.py | 2 +-
.../airflow/providers/amazon/aws/sensors/ecs.py | 2 +-
.../airflow/providers/amazon/aws/sensors/eks.py | 3 +-
.../airflow/providers/amazon/aws/sensors/emr.py | 4 +-
.../providers/amazon/aws/sensors/glacier.py | 2 +-
.../airflow/providers/amazon/aws/sensors/glue.py | 2 +-
.../amazon/aws/sensors/glue_catalog_partition.py | 2 +-
.../providers/amazon/aws/sensors/glue_crawler.py | 2 +-
.../amazon/aws/sensors/kinesis_analytics.py | 2 +-
.../amazon/aws/sensors/lambda_function.py | 2 +-
.../airflow/providers/amazon/aws/sensors/mwaa.py | 2 +-
.../amazon/aws/sensors/opensearch_serverless.py | 2 +-
.../providers/amazon/aws/sensors/quicksight.py | 2 +-
.../airflow/providers/amazon/aws/sensors/rds.py | 2 +-
.../amazon/aws/sensors/redshift_cluster.py | 2 +-
.../src/airflow/providers/amazon/aws/sensors/s3.py | 3 +-
.../providers/amazon/aws/sensors/sagemaker.py | 2 +-
.../amazon/aws/sensors/sagemaker_unified_studio.py | 3 +-
.../airflow/providers/amazon/aws/sensors/sqs.py | 2 +-
.../providers/amazon/aws/sensors/step_function.py | 2 +-
.../providers/amazon/aws/transfers/gcs_to_s3.py | 3 +-
.../amazon/aws/transfers/redshift_to_s3.py | 3 +-
.../amazon/aws/transfers/s3_to_dynamodb.py | 3 +-
.../amazon/aws/transfers/s3_to_redshift.py | 3 +-
.../providers/amazon/aws/transfers/s3_to_sql.py | 3 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 4 +-
.../airflow/providers/amazon/aws/triggers/ecs.py | 2 +-
.../airflow/providers/amazon/aws/triggers/eks.py | 2 +-
.../providers/amazon/aws/triggers/sagemaker.py | 2 +-
.../airflow/providers/amazon/aws/triggers/sqs.py | 2 +-
.../airflow/providers/amazon/aws/utils/__init__.py | 2 +-
.../amazon/aws/utils/connection_wrapper.py | 2 +-
.../airflow/providers/amazon/aws/utils/waiter.py | 2 +-
.../amazon/aws/utils/waiter_with_logging.py | 2 +-
.../tests/system/amazon/aws/example_appflow.py | 1 -
.../tests/system/amazon/aws/example_appflow_run.py | 1 -
.../tests/system/amazon/aws/example_athena.py | 1 -
.../system/amazon/aws/example_azure_blob_to_s3.py | 1 -
.../tests/system/amazon/aws/example_batch.py | 1 -
.../tests/system/amazon/aws/example_bedrock.py | 1 -
.../amazon/aws/example_bedrock_batch_inference.py | 1 -
.../aws/example_bedrock_retrieve_and_generate.py | 1 -
.../system/amazon/aws/example_cloudformation.py | 1 -
.../tests/system/amazon/aws/example_comprehend.py | 1 -
.../aws/example_comprehend_document_classifier.py | 1 -
.../tests/system/amazon/aws/example_datasync.py | 1 -
.../amazon/tests/system/amazon/aws/example_dms.py | 1 -
.../tests/system/amazon/aws/example_dynamodb.py | 1 -
.../system/amazon/aws/example_dynamodb_to_s3.py | 3 +-
.../amazon/tests/system/amazon/aws/example_ec2.py | 1 -
.../amazon/tests/system/amazon/aws/example_ecs.py | 1 -
.../tests/system/amazon/aws/example_ecs_fargate.py | 1 -
.../system/amazon/aws/example_eks_templated.py | 1 -
.../aws/example_eks_with_fargate_in_one_step.py | 1 -
.../amazon/aws/example_eks_with_fargate_profile.py | 1 -
.../aws/example_eks_with_nodegroup_in_one_step.py | 1 -
.../amazon/aws/example_eks_with_nodegroups.py | 1 -
.../amazon/tests/system/amazon/aws/example_emr.py | 1 -
.../tests/system/amazon/aws/example_emr_eks.py | 1 -
.../amazon/aws/example_emr_notebook_execution.py | 1 -
.../system/amazon/aws/example_emr_serverless.py | 1 -
.../tests/system/amazon/aws/example_eventbridge.py | 1 -
.../tests/system/amazon/aws/example_ftp_to_s3.py | 1 -
.../tests/system/amazon/aws/example_gcs_to_s3.py | 1 -
.../system/amazon/aws/example_glacier_to_gcs.py | 1 -
.../amazon/tests/system/amazon/aws/example_glue.py | 1 -
.../system/amazon/aws/example_glue_data_quality.py | 1 -
...xample_glue_data_quality_with_recommendation.py | 1 -
.../amazon/aws/example_google_api_sheets_to_s3.py | 1 -
.../amazon/aws/example_google_api_youtube_to_s3.py | 1 -
.../system/amazon/aws/example_hive_to_dynamodb.py | 1 -
.../tests/system/amazon/aws/example_http_to_s3.py | 1 -
.../amazon/aws/example_imap_attachment_to_s3.py | 1 -
.../system/amazon/aws/example_kinesis_analytics.py | 1 -
.../tests/system/amazon/aws/example_lambda.py | 1 -
.../tests/system/amazon/aws/example_local_to_s3.py | 1 -
.../tests/system/amazon/aws/example_mongo_to_s3.py | 1 -
.../amazon/tests/system/amazon/aws/example_mwaa.py | 1 -
.../system/amazon/aws/example_mwaa_airflow2.py | 1 -
.../tests/system/amazon/aws/example_neptune.py | 1 -
.../tests/system/amazon/aws/example_quicksight.py | 1 -
.../tests/system/amazon/aws/example_rds_event.py | 1 -
.../tests/system/amazon/aws/example_rds_export.py | 1 -
.../system/amazon/aws/example_rds_instance.py | 1 -
.../system/amazon/aws/example_rds_snapshot.py | 1 -
.../tests/system/amazon/aws/example_redshift.py | 1 -
.../amazon/aws/example_redshift_s3_transfers.py | 1 -
.../amazon/tests/system/amazon/aws/example_s3.py | 1 -
.../system/amazon/aws/example_s3_to_dynamodb.py | 1 -
.../tests/system/amazon/aws/example_s3_to_ftp.py | 1 -
.../tests/system/amazon/aws/example_s3_to_sftp.py | 1 -
.../tests/system/amazon/aws/example_s3_to_sql.py | 1 -
.../tests/system/amazon/aws/example_sagemaker.py | 1 -
.../amazon/aws/example_sagemaker_endpoint.py | 1 -
.../amazon/aws/example_sagemaker_notebook.py | 1 -
.../amazon/aws/example_sagemaker_pipeline.py | 1 -
.../amazon/aws/example_sagemaker_unified_studio.py | 1 -
.../system/amazon/aws/example_salesforce_to_s3.py | 1 -
.../tests/system/amazon/aws/example_sftp_to_s3.py | 1 -
.../amazon/tests/system/amazon/aws/example_sns.py | 1 -
.../tests/system/amazon/aws/example_sql_to_s3.py | 1 -
.../amazon/tests/system/amazon/aws/example_sqs.py | 1 -
.../amazon/tests/system/amazon/aws/example_ssm.py | 1 -
.../system/amazon/aws/example_step_functions.py | 1 -
.../amazon/aws/tests/test_aws_auth_manager.py | 13 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 2 +-
.../tests/unit/amazon/aws/bundles/test_s3.py | 2 +-
.../executors/aws_lambda/test_lambda_executor.py | 2 +-
.../aws/executors/batch/test_batch_executor.py | 2 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 2 +-
.../unit/amazon/aws/hooks/test_batch_client.py | 2 +-
.../unit/amazon/aws/hooks/test_batch_waiters.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_chime.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 | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ec2.py | 2 +-
.../hooks/test_elasticache_replication_group.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_emr.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_glue.py | 2 +-
.../unit/amazon/aws/hooks/test_glue_catalog.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_quicksight.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_rds.py | 2 +-
.../unit/amazon/aws/hooks/test_redshift_sql.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_sagemaker.py | 2 +-
.../aws/hooks/test_sagemaker_unified_studio.py | 2 +-
.../unit/amazon/aws/hooks/test_step_function.py | 2 +-
.../amazon/tests/unit/amazon/aws/links/test_emr.py | 2 +-
.../tests/unit/amazon/aws/operators/test_athena.py | 2 +-
.../tests/unit/amazon/aws/operators/test_batch.py | 2 +-
.../unit/amazon/aws/operators/test_datasync.py | 2 +-
.../tests/unit/amazon/aws/operators/test_dms.py | 2 +-
.../tests/unit/amazon/aws/operators/test_ec2.py | 2 +-
.../tests/unit/amazon/aws/operators/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/operators/test_eks.py | 3 +-
.../amazon/aws/operators/test_emr_add_steps.py | 2 +-
.../amazon/aws/operators/test_emr_containers.py | 2 +-
.../aws/operators/test_emr_create_job_flow.py | 3 +-
.../aws/operators/test_emr_modify_cluster.py | 2 +-
.../aws/operators/test_emr_notebook_execution.py | 2 +-
.../amazon/aws/operators/test_emr_serverless.py | 2 +-
.../aws/operators/test_emr_terminate_job_flow.py | 2 +-
.../unit/amazon/aws/operators/test_eventbridge.py | 2 +-
.../tests/unit/amazon/aws/operators/test_glue.py | 2 +-
.../amazon/aws/operators/test_kinesis_analytics.py | 2 +-
.../amazon/aws/operators/test_lambda_function.py | 2 +-
.../unit/amazon/aws/operators/test_neptune.py | 2 +-
.../tests/unit/amazon/aws/operators/test_rds.py | 2 +-
.../amazon/aws/operators/test_redshift_cluster.py | 2 +-
.../amazon/aws/operators/test_redshift_data.py | 2 +-
.../tests/unit/amazon/aws/operators/test_s3.py | 2 +-
.../amazon/aws/operators/test_sagemaker_base.py | 2 +-
.../aws/operators/test_sagemaker_endpoint.py | 2 +-
.../operators/test_sagemaker_endpoint_config.py | 2 +-
.../amazon/aws/operators/test_sagemaker_model.py | 2 +-
.../aws/operators/test_sagemaker_pipeline.py | 2 +-
.../aws/operators/test_sagemaker_processing.py | 2 +-
.../aws/operators/test_sagemaker_training.py | 2 +-
.../aws/operators/test_sagemaker_transform.py | 2 +-
.../amazon/aws/operators/test_sagemaker_tuning.py | 2 +-
.../aws/operators/test_sagemaker_unified_studio.py | 2 +-
.../amazon/aws/operators/test_step_function.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_athena.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_batch.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_bedrock.py | 2 +-
.../unit/amazon/aws/sensors/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_dms.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ec2.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_eks.py | 3 +-
.../tests/unit/amazon/aws/sensors/test_emr_base.py | 2 +-
.../unit/amazon/aws/sensors/test_emr_containers.py | 2 +-
.../unit/amazon/aws/sensors/test_emr_job_flow.py | 2 +-
.../aws/sensors/test_emr_notebook_execution.py | 2 +-
.../aws/sensors/test_emr_serverless_application.py | 2 +-
.../amazon/aws/sensors/test_emr_serverless_job.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_emr_step.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_glacier.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_glue.py | 2 +-
.../aws/sensors/test_glue_catalog_partition.py | 2 +-
.../unit/amazon/aws/sensors/test_glue_crawler.py | 2 +-
.../amazon/aws/sensors/test_glue_data_quality.py | 2 +-
.../amazon/aws/sensors/test_kinesis_analytics.py | 2 +-
.../amazon/aws/sensors/test_lambda_function.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_mwaa.py | 2 +-
.../aws/sensors/test_opensearch_serverless.py | 2 +-
.../unit/amazon/aws/sensors/test_quicksight.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_rds.py | 2 +-
.../amazon/aws/sensors/test_redshift_cluster.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_s3.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_automl.py | 2 +-
.../unit/amazon/aws/sensors/test_sagemaker_base.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_endpoint.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_pipeline.py | 2 +-
.../aws/sensors/test_sagemaker_processing.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_training.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_transform.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_tuning.py | 2 +-
.../aws/sensors/test_sagemaker_unified_studio.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_sqs.py | 2 +-
.../unit/amazon/aws/sensors/test_step_function.py | 2 +-
.../amazon/aws/transfers/test_redshift_to_s3.py | 2 +-
.../amazon/aws/transfers/test_s3_to_dynamodb.py | 2 +-
.../amazon/aws/transfers/test_s3_to_redshift.py | 2 +-
.../unit/amazon/aws/transfers/test_s3_to_sql.py | 2 +-
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 3 +-
.../tests/unit/amazon/aws/triggers/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_eks.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_glue.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_neptune.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_ssm.py | 2 +-
.../amazon/aws/utils/test_connection_wrapper.py | 2 +-
.../tests/unit/amazon/aws/utils/test_waiter.py | 2 +-
.../amazon/aws/utils/test_waiter_with_logging.py | 2 +-
providers/apache/beam/pyproject.toml | 4 +-
.../airflow/providers/apache/beam/hooks/beam.py | 4 +-
.../providers/apache/beam/operators/beam.py | 4 +-
.../beam/tests/unit/apache/beam/hooks/test_beam.py | 2 +-
.../tests/unit/apache/beam/operators/test_beam.py | 3 +-
providers/apache/druid/pyproject.toml | 2 +-
.../airflow/providers/apache/druid/hooks/druid.py | 3 +-
.../tests/unit/apache/druid/hooks/test_druid.py | 2 +-
providers/apache/flink/pyproject.toml | 8 +-
.../apache/flink/sensors/flink_kubernetes.py | 3 +-
.../apache/flink/sensors/test_flink_kubernetes.py | 2 +-
providers/apache/hdfs/pyproject.toml | 8 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 3 +-
providers/apache/hive/pyproject.toml | 2 +-
.../airflow/providers/apache/hive/hooks/hive.py | 3 +-
.../providers/apache/hive/operators/hive_stats.py | 3 +-
.../providers/apache/hive/transfers/s3_to_hive.py | 3 +-
.../hive/tests/unit/apache/hive/hooks/test_hive.py | 3 +-
.../unit/apache/hive/operators/test_hive_stats.py | 2 +-
.../hive/sensors/test_named_hive_partition.py | 2 +-
.../unit/apache/hive/transfers/test_s3_to_hive.py | 2 +-
providers/apache/kafka/pyproject.toml | 4 +-
.../providers/apache/kafka/operators/consume.py | 3 +-
.../providers/apache/kafka/operators/produce.py | 3 +-
.../apache/kafka/triggers/await_message.py | 2 +-
.../unit/apache/kafka/operators/test_consume.py | 2 +-
.../tests/unit/apache/kafka/sensors/test_kafka.py | 2 +-
providers/apache/kylin/pyproject.toml | 2 +-
.../airflow/providers/apache/kylin/hooks/kylin.py | 3 +-
.../providers/apache/kylin/operators/kylin_cube.py | 3 +-
.../tests/unit/apache/kylin/hooks/test_kylin.py | 2 +-
.../unit/apache/kylin/operators/test_kylin_cube.py | 2 +-
providers/apache/livy/pyproject.toml | 2 +-
.../airflow/providers/apache/livy/hooks/livy.py | 2 +-
.../providers/apache/livy/operators/livy.py | 3 +-
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 2 +-
.../tests/unit/apache/livy/operators/test_livy.py | 2 +-
providers/apache/pig/pyproject.toml | 8 +-
.../src/airflow/providers/apache/pig/hooks/pig.py | 3 +-
.../pig/tests/unit/apache/pig/hooks/test_pig.py | 2 +-
providers/apache/pinot/pyproject.toml | 8 +-
.../airflow/providers/apache/pinot/hooks/pinot.py | 3 +-
.../tests/unit/apache/pinot/hooks/test_pinot.py | 2 +-
providers/apache/spark/pyproject.toml | 2 +-
.../providers/apache/spark/hooks/spark_jdbc.py | 2 +-
.../providers/apache/spark/hooks/spark_sql.py | 3 +-
.../providers/apache/spark/hooks/spark_submit.py | 3 +-
.../unit/apache/spark/hooks/test_spark_sql.py | 2 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 2 +-
providers/arangodb/pyproject.toml | 2 +-
.../airflow/providers/arangodb/hooks/arangodb.py | 3 +-
.../providers/arangodb/operators/arangodb.py | 3 +-
providers/atlassian/jira/pyproject.toml | 2 +-
.../airflow/providers/atlassian/jira/hooks/jira.py | 3 +-
providers/celery/pyproject.toml | 2 +-
.../celery/executors/celery_executor_utils.py | 3 +-
.../providers/celery/executors/default_celery.py | 3 +-
.../integration/celery/test_celery_executor.py | 2 +-
providers/cloudant/pyproject.toml | 2 +-
.../airflow/providers/cloudant/hooks/cloudant.py | 3 +-
.../tests/unit/cloudant/hooks/test_cloudant.py | 2 +-
providers/cncf/kubernetes/pyproject.toml | 2 +-
.../backcompat/backwards_compat_converters.py | 2 +-
.../providers/cncf/kubernetes/exceptions.py | 6 +
.../executors/kubernetes_executor_utils.py | 2 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 3 +-
.../cncf/kubernetes/kubernetes_helper_functions.py | 2 +-
.../kubernetes/operators/custom_object_launcher.py | 2 +-
.../providers/cncf/kubernetes/operators/job.py | 3 +-
.../providers/cncf/kubernetes/operators/kueue.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 2 +-
.../cncf/kubernetes/operators/resource.py | 2 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 2 +-
.../kubernetes/resource_convert/env_variable.py | 2 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 3 +-
.../cncf/kubernetes/template_rendering.py | 2 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
.../backcompat/test_backwards_compat_converters.py | 2 +-
.../executors/test_kubernetes_executor.py | 2 +-
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 2 +-
.../operators/test_custom_object_launcher.py | 2 +-
.../unit/cncf/kubernetes/operators/test_job.py | 3 +-
.../unit/cncf/kubernetes/operators/test_kueue.py | 2 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 12 +-
.../kubernetes/operators/test_spark_kubernetes.py | 2 +-
.../kubernetes/sensors/test_spark_kubernetes.py | 2 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 2 +-
.../src/airflow/providers/common/compat/sdk.py | 13 +-
providers/common/sql/pyproject.toml | 2 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 8 +-
.../common/sql/operators/generic_transfer.py | 3 +-
.../airflow/providers/common/sql/operators/sql.py | 2 +-
.../airflow/providers/common/sql/sensors/sql.py | 3 +-
.../airflow/providers/common/sql/triggers/sql.py | 3 +-
.../tests/unit/common/sql/operators/test_sql.py | 13 +-
.../sql/tests/unit/common/sql/sensors/test_sql.py | 2 +-
providers/databricks/pyproject.toml | 2 +-
.../src/airflow/providers/databricks/exceptions.py | 2 +-
.../providers/databricks/hooks/databricks.py | 2 +-
.../providers/databricks/hooks/databricks_base.py | 3 +-
.../providers/databricks/hooks/databricks_sql.py | 2 +-
.../providers/databricks/operators/databricks.py | 3 +-
.../databricks/operators/databricks_repos.py | 3 +-
.../databricks/operators/databricks_sql.py | 3 +-
.../databricks/operators/databricks_workflow.py | 3 +-
.../databricks/plugins/databricks_workflow.py | 4 +-
.../providers/databricks/sensors/databricks.py | 3 +-
.../databricks/sensors/databricks_partition.py | 3 +-
.../providers/databricks/sensors/databricks_sql.py | 3 +-
.../providers/databricks/utils/databricks.py | 2 +-
.../airflow/providers/databricks/utils/mixins.py | 2 +-
.../providers/databricks/utils/openlineage.py | 88 +---
.../tests/unit/databricks/hooks/test_databricks.py | 2 +-
.../unit/databricks/hooks/test_databricks_base.py | 2 +-
.../unit/databricks/hooks/test_databricks_sql.py | 5 +-
.../unit/databricks/operators/test_databricks.py | 2 +-
.../databricks/operators/test_databricks_copy.py | 2 +-
.../databricks/operators/test_databricks_repos.py | 2 +-
.../operators/test_databricks_workflow.py | 2 +-
.../databricks/plugins/test_databricks_workflow.py | 2 +-
.../unit/databricks/sensors/test_databricks.py | 2 +-
.../sensors/test_databricks_partition.py | 2 +-
.../unit/databricks/sensors/test_databricks_sql.py | 2 +-
.../tests/unit/databricks/utils/test_databricks.py | 2 +-
.../tests/unit/databricks/utils/test_mixins.py | 2 +-
.../unit/databricks/utils/test_openlineage.py | 60 +--
providers/datadog/pyproject.toml | 2 +-
.../src/airflow/providers/datadog/hooks/datadog.py | 3 +-
.../airflow/providers/datadog/sensors/datadog.py | 3 +-
.../tests/unit/datadog/hooks/test_datadog.py | 2 +-
.../tests/unit/datadog/sensors/test_datadog.py | 2 +-
providers/dbt/cloud/pyproject.toml | 2 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 2 +-
.../src/airflow/providers/dbt/cloud/sensors/dbt.py | 3 +-
.../providers/dbt/cloud/utils/openlineage.py | 79 +--
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 2 +-
.../tests/unit/dbt/cloud/operators/test_dbt.py | 3 +-
.../cloud/tests/unit/dbt/cloud/sensors/test_dbt.py | 5 +-
.../tests/unit/dbt/cloud/utils/test_openlineage.py | 41 +-
providers/dingding/pyproject.toml | 2 +-
.../airflow/providers/dingding/hooks/dingding.py | 2 +-
providers/discord/pyproject.toml | 2 +-
.../providers/discord/operators/discord_webhook.py | 2 +-
providers/docker/pyproject.toml | 2 +-
.../airflow/providers/docker/decorators/docker.py | 2 +-
.../src/airflow/providers/docker/exceptions.py | 3 +-
.../src/airflow/providers/docker/hooks/docker.py | 3 +-
.../providers/docker/operators/docker_swarm.py | 2 +-
.../tests/unit/docker/decorators/test_docker.py | 2 +-
.../docker/tests/unit/docker/hooks/test_docker.py | 2 +-
.../tests/unit/docker/operators/test_docker.py | 2 +-
.../unit/docker/operators/test_docker_swarm.py | 2 +-
.../edge3/example_dags/integration_test.py | 2 +-
.../providers/edge3/example_dags/win_test.py | 7 +-
.../airflow/providers/edge3/models/edge_worker.py | 3 +-
providers/elasticsearch/pyproject.toml | 2 +-
.../providers/elasticsearch/log/es_task_handler.py | 3 +-
providers/fab/pyproject.toml | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 3 +-
.../providers/fab/auth_manager/models/db.py | 2 +-
.../fab/auth_manager/security_manager/override.py | 2 +-
.../providers/fab/www/extensions/init_security.py | 2 +-
.../tests/unit/fab/auth_manager/test_security.py | 2 +-
.../unit/fab/db_manager/test_fab_db_manager.py | 2 +-
providers/fab/www-hash.txt | 2 +-
providers/facebook/pyproject.toml | 2 +-
.../airflow/providers/facebook/ads/hooks/ads.py | 3 +-
providers/git/pyproject.toml | 2 +-
.../git/src/airflow/providers/git/bundles/git.py | 7 +-
.../git/src/airflow/providers/git/hooks/git.py | 3 +-
providers/git/tests/unit/git/bundles/test_git.py | 37 +-
providers/git/tests/unit/git/hooks/test_git.py | 2 +-
providers/github/pyproject.toml | 2 +-
.../airflow/providers/github/operators/github.py | 3 +-
.../src/airflow/providers/github/sensors/github.py | 3 +-
.../github/tests/system/github/example_github.py | 2 +-
providers/google/pyproject.toml | 2 +-
.../src/airflow/providers/google/ads/hooks/ads.py | 3 +-
.../airflow/providers/google/cloud/bundles/gcs.py | 2 +-
.../providers/google/cloud/hooks/alloy_db.py | 2 +-
.../providers/google/cloud/hooks/bigquery.py | 7 +-
.../providers/google/cloud/hooks/cloud_batch.py | 2 +-
.../providers/google/cloud/hooks/cloud_build.py | 2 +-
.../providers/google/cloud/hooks/cloud_composer.py | 2 +-
.../google/cloud/hooks/cloud_memorystore.py | 2 +-
.../providers/google/cloud/hooks/cloud_run.py | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 2 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 3 +-
.../providers/google/cloud/hooks/compute.py | 2 +-
.../providers/google/cloud/hooks/compute_ssh.py | 2 +-
.../providers/google/cloud/hooks/datacatalog.py | 3 +-
.../providers/google/cloud/hooks/dataflow.py | 4 +-
.../providers/google/cloud/hooks/dataform.py | 2 +-
.../providers/google/cloud/hooks/datafusion.py | 2 +-
.../providers/google/cloud/hooks/dataplex.py | 2 +-
.../providers/google/cloud/hooks/dataproc.py | 2 +-
.../google/cloud/hooks/dataproc_metastore.py | 2 +-
.../airflow/providers/google/cloud/hooks/dlp.py | 2 +-
.../providers/google/cloud/hooks/functions.py | 2 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 4 +-
.../airflow/providers/google/cloud/hooks/gdm.py | 2 +-
.../google/cloud/hooks/kubernetes_engine.py | 2 +-
.../airflow/providers/google/cloud/hooks/looker.py | 3 +-
.../providers/google/cloud/hooks/managed_kafka.py | 2 +-
.../providers/google/cloud/hooks/mlengine.py | 2 +-
.../providers/google/cloud/hooks/spanner.py | 2 +-
.../providers/google/cloud/hooks/stackdriver.py | 2 +-
.../airflow/providers/google/cloud/hooks/tasks.py | 2 +-
.../providers/google/cloud/hooks/translate.py | 2 +-
.../google/cloud/hooks/vertex_ai/auto_ml.py | 3 +-
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/feature_store.py | 2 +-
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/model_service.py | 2 +-
.../google/cloud/hooks/vertex_ai/pipeline_job.py | 2 +-
.../airflow/providers/google/cloud/hooks/vision.py | 2 +-
.../providers/google/cloud/log/gcs_task_handler.py | 2 +-
.../providers/google/cloud/operators/alloy_db.py | 2 +-
.../providers/google/cloud/operators/bigquery.py | 4 +-
.../google/cloud/operators/bigquery_dts.py | 2 +-
.../providers/google/cloud/operators/bigtable.py | 2 +-
.../google/cloud/operators/cloud_batch.py | 2 +-
.../google/cloud/operators/cloud_build.py | 2 +-
.../google/cloud/operators/cloud_composer.py | 2 +-
.../google/cloud/operators/cloud_logging_sink.py | 2 +-
.../providers/google/cloud/operators/cloud_run.py | 2 +-
.../providers/google/cloud/operators/cloud_sql.py | 3 +-
.../operators/cloud_storage_transfer_service.py | 2 +-
.../providers/google/cloud/operators/compute.py | 2 +-
.../providers/google/cloud/operators/dataflow.py | 2 +-
.../providers/google/cloud/operators/datafusion.py | 2 +-
.../providers/google/cloud/operators/dataplex.py | 2 +-
.../providers/google/cloud/operators/dataproc.py | 3 +-
.../google/cloud/operators/dataproc_metastore.py | 2 +-
.../providers/google/cloud/operators/datastore.py | 2 +-
.../providers/google/cloud/operators/functions.py | 2 +-
.../providers/google/cloud/operators/gcs.py | 3 +-
.../google/cloud/operators/kubernetes_engine.py | 3 +-
.../providers/google/cloud/operators/looker.py | 2 +-
.../google/cloud/operators/managed_kafka.py | 2 +-
.../providers/google/cloud/operators/pubsub.py | 2 +-
.../providers/google/cloud/operators/spanner.py | 2 +-
.../google/cloud/operators/speech_to_text.py | 2 +-
.../google/cloud/operators/text_to_speech.py | 2 +-
.../providers/google/cloud/operators/translate.py | 2 +-
.../google/cloud/operators/translate_speech.py | 2 +-
.../operators/vertex_ai/batch_prediction_job.py | 2 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 2 +-
.../google/cloud/operators/vertex_ai/dataset.py | 2 +-
.../operators/vertex_ai/experiment_service.py | 2 +-
.../cloud/operators/vertex_ai/feature_store.py | 2 +-
.../cloud/operators/vertex_ai/generative_model.py | 3 +-
.../vertex_ai/hyperparameter_tuning_job.py | 2 +-
.../cloud/operators/vertex_ai/pipeline_job.py | 2 +-
.../google/cloud/operators/vertex_ai/ray.py | 2 +-
.../google/cloud/secrets/secret_manager.py | 2 +-
.../providers/google/cloud/sensors/bigquery.py | 4 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 3 +-
.../google/cloud/sensors/cloud_composer.py | 3 +-
.../sensors/cloud_storage_transfer_service.py | 3 +-
.../providers/google/cloud/sensors/dataflow.py | 3 +-
.../providers/google/cloud/sensors/dataform.py | 3 +-
.../providers/google/cloud/sensors/datafusion.py | 3 +-
.../providers/google/cloud/sensors/dataplex.py | 3 +-
.../providers/google/cloud/sensors/dataproc.py | 3 +-
.../google/cloud/sensors/dataproc_metastore.py | 3 +-
.../airflow/providers/google/cloud/sensors/gcs.py | 3 +-
.../providers/google/cloud/sensors/looker.py | 3 +-
.../providers/google/cloud/sensors/pubsub.py | 3 +-
.../cloud/sensors/vertex_ai/feature_store.py | 3 +-
.../providers/google/cloud/sensors/workflows.py | 3 +-
.../cloud/transfers/azure_fileshare_to_gcs.py | 3 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 2 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 2 +-
.../google/cloud/transfers/facebook_ads_to_gcs.py | 2 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 2 +-
.../providers/google/cloud/transfers/gcs_to_gcs.py | 3 +-
.../google/cloud/transfers/gcs_to_local.py | 2 +-
.../google/cloud/transfers/gcs_to_sftp.py | 2 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 2 +-
.../google/cloud/transfers/sftp_to_gcs.py | 2 +-
.../providers/google/cloud/triggers/bigquery.py | 2 +-
.../google/cloud/triggers/cloud_composer.py | 2 +-
.../providers/google/cloud/triggers/cloud_run.py | 2 +-
.../triggers/cloud_storage_transfer_service.py | 2 +-
.../providers/google/cloud/triggers/dataproc.py | 2 +-
.../google/cloud/triggers/kubernetes_engine.py | 3 +-
.../providers/google/cloud/triggers/vertex_ai.py | 2 +-
.../google/cloud/utils/credentials_provider.py | 2 +-
.../google/cloud/utils/field_sanitizer.py | 2 +-
.../google/cloud/utils/field_validator.py | 2 +-
.../providers/google/common/hooks/base_google.py | 3 +-
.../google/common/hooks/operation_helpers.py | 2 +-
.../providers/google/firebase/hooks/firestore.py | 2 +-
.../google/firebase/operators/firestore.py | 2 +-
.../providers/google/leveldb/hooks/leveldb.py | 4 +-
.../marketing_platform/hooks/campaign_manager.py | 2 +-
.../google/marketing_platform/hooks/search_ads.py | 2 +-
.../operators/analytics_admin.py | 2 +-
.../operators/campaign_manager.py | 2 +-
.../marketing_platform/sensors/display_video.py | 3 +-
.../providers/google/suite/hooks/calendar.py | 2 +-
.../airflow/providers/google/suite/hooks/sheets.py | 2 +-
.../google/suite/transfers/gcs_to_gdrive.py | 2 +-
.../cloud_build/example_cloud_build_trigger.py | 2 +-
.../cloud/composer/example_cloud_composer.py | 2 +-
.../example_dataflow_native_python_async.py | 2 +-
.../example_dataflow_sensors_deferrable.py | 2 +-
.../google/tests/unit/google/ads/hooks/test_ads.py | 2 +-
.../tests/unit/google/cloud/hooks/test_alloy_db.py | 2 +-
.../tests/unit/google/cloud/hooks/test_bigquery.py | 3 +-
.../unit/google/cloud/hooks/test_cloud_batch.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_build.py | 2 +-
.../google/cloud/hooks/test_cloud_memorystore.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_run.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 2 +-
.../hooks/test_cloud_storage_transfer_service.py | 2 +-
.../test_cloud_storage_transfer_service_async.py | 2 +-
.../tests/unit/google/cloud/hooks/test_compute.py | 2 +-
.../unit/google/cloud/hooks/test_compute_ssh.py | 2 +-
.../unit/google/cloud/hooks/test_datacatalog.py | 3 +-
.../tests/unit/google/cloud/hooks/test_dataflow.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dataform.py | 2 +-
.../unit/google/cloud/hooks/test_datafusion.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dataproc.py | 2 +-
.../unit/google/cloud/hooks/test_datastore.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dlp.py | 2 +-
.../unit/google/cloud/hooks/test_functions.py | 2 +-
.../tests/unit/google/cloud/hooks/test_gcs.py | 2 +-
.../tests/unit/google/cloud/hooks/test_gdm.py | 2 +-
.../google/cloud/hooks/test_kubernetes_engine.py | 2 +-
.../tests/unit/google/cloud/hooks/test_looker.py | 2 +-
.../tests/unit/google/cloud/hooks/test_mlengine.py | 2 +-
.../tests/unit/google/cloud/hooks/test_os_login.py | 2 +-
.../tests/unit/google/cloud/hooks/test_vision.py | 2 +-
.../hooks/vertex_ai/test_batch_prediction_job.py | 2 +-
.../cloud/hooks/vertex_ai/test_custom_job.py | 2 +-
.../vertex_ai/test_hyperparameter_tuning_job.py | 2 +-
.../cloud/hooks/vertex_ai/test_pipeline_job.py | 2 +-
.../unit/google/cloud/operators/test_alloy_db.py | 2 +-
.../unit/google/cloud/operators/test_bigquery.py | 12 +-
.../unit/google/cloud/operators/test_bigtable.py | 2 +-
.../google/cloud/operators/test_cloud_batch.py | 2 +-
.../google/cloud/operators/test_cloud_build.py | 2 +-
.../google/cloud/operators/test_cloud_composer.py | 2 +-
.../cloud/operators/test_cloud_logging_sink.py | 2 +-
.../unit/google/cloud/operators/test_cloud_run.py | 2 +-
.../unit/google/cloud/operators/test_cloud_sql.py | 2 +-
.../test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/operators/test_compute.py | 2 +-
.../unit/google/cloud/operators/test_dataflow.py | 2 +-
.../unit/google/cloud/operators/test_datafusion.py | 2 +-
.../unit/google/cloud/operators/test_dataplex.py | 2 +-
.../unit/google/cloud/operators/test_dataproc.py | 8 +-
.../unit/google/cloud/operators/test_functions.py | 2 +-
.../cloud/operators/test_kubernetes_engine.py | 6 +-
.../unit/google/cloud/operators/test_looker.py | 2 +-
.../unit/google/cloud/operators/test_pubsub.py | 2 +-
.../unit/google/cloud/operators/test_spanner.py | 2 +-
.../google/cloud/operators/test_speech_to_text.py | 2 +-
.../google/cloud/operators/test_text_to_speech.py | 2 +-
.../cloud/operators/test_translate_speech.py | 2 +-
.../unit/google/cloud/operators/test_vertex_ai.py | 3 +-
.../google/cloud/secrets/test_secret_manager.py | 2 +-
.../unit/google/cloud/sensors/test_bigquery.py | 5 +-
.../unit/google/cloud/sensors/test_bigquery_dts.py | 2 +-
.../unit/google/cloud/sensors/test_bigtable.py | 2 +-
.../sensors/test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/sensors/test_dataflow.py | 2 +-
.../unit/google/cloud/sensors/test_dataform.py | 2 +-
.../unit/google/cloud/sensors/test_datafusion.py | 2 +-
.../unit/google/cloud/sensors/test_dataplex.py | 2 +-
.../unit/google/cloud/sensors/test_dataproc.py | 2 +-
.../cloud/sensors/test_dataproc_metastore.py | 2 +-
.../tests/unit/google/cloud/sensors/test_gcs.py | 2 +-
.../tests/unit/google/cloud/sensors/test_looker.py | 2 +-
.../tests/unit/google/cloud/sensors/test_pubsub.py | 2 +-
.../unit/google/cloud/sensors/test_vertex_ai.py | 2 +-
.../unit/google/cloud/sensors/test_workflows.py | 2 +-
.../google/cloud/transfers/test_bigquery_to_gcs.py | 2 +-
.../google/cloud/transfers/test_gcs_to_bigquery.py | 2 +-
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 3 +-
.../google/cloud/transfers/test_gcs_to_local.py | 2 +-
.../google/cloud/transfers/test_gcs_to_sftp.py | 2 +-
.../unit/google/cloud/transfers/test_s3_to_gcs.py | 2 +-
.../google/cloud/transfers/test_sftp_to_gcs.py | 2 +-
.../test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/triggers/test_vertex_ai.py | 2 +-
.../unit/google/cloud/utils/gcp_authenticator.py | 2 +-
.../cloud/utils/test_credentials_provider.py | 2 +-
.../unit/google/common/hooks/test_base_google.py | 2 +-
.../unit/google/firebase/hooks/test_firestore.py | 2 +-
.../operators/test_analytics_admin.py | 2 +-
.../sensors/test_display_video.py | 2 +-
.../tests/unit/google/suite/hooks/test_sheets.py | 2 +-
.../google/suite/transfers/test_gcs_to_gdrive.py | 2 +-
providers/http/pyproject.toml | 2 +-
.../http/src/airflow/providers/http/exceptions.py | 2 +-
.../http/src/airflow/providers/http/hooks/http.py | 3 +-
.../src/airflow/providers/http/operators/http.py | 3 +-
.../src/airflow/providers/http/sensors/http.py | 3 +-
.../src/airflow/providers/http/triggers/http.py | 2 +-
providers/http/tests/unit/http/hooks/test_http.py | 2 +-
.../http/tests/unit/http/operators/test_http.py | 2 +-
.../http/tests/unit/http/sensors/test_http.py | 2 +-
providers/imap/pyproject.toml | 2 +-
.../imap/src/airflow/providers/imap/hooks/imap.py | 3 +-
providers/imap/tests/unit/imap/hooks/test_imap.py | 2 +-
providers/jdbc/pyproject.toml | 2 +-
.../jdbc/src/airflow/providers/jdbc/hooks/jdbc.py | 2 +-
providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 2 +-
providers/jenkins/pyproject.toml | 2 +-
.../jenkins/operators/jenkins_job_trigger.py | 3 +-
.../airflow/providers/jenkins/sensors/jenkins.py | 3 +-
.../jenkins/operators/test_jenkins_job_trigger.py | 2 +-
.../tests/unit/jenkins/sensors/test_jenkins.py | 2 +-
providers/keycloak/pyproject.toml | 2 +
.../keycloak/auth_manager/keycloak_auth_manager.py | 2 +-
.../auth_manager/test_keycloak_auth_manager.py | 2 +-
providers/microsoft/azure/pyproject.toml | 2 +-
.../airflow/providers/microsoft/azure/hooks/adx.py | 3 +-
.../providers/microsoft/azure/hooks/base_azure.py | 3 +-
.../providers/microsoft/azure/hooks/batch.py | 3 +-
.../microsoft/azure/hooks/container_instance.py | 2 +-
.../providers/microsoft/azure/hooks/cosmos.py | 4 +-
.../microsoft/azure/hooks/data_factory.py | 3 +-
.../providers/microsoft/azure/hooks/data_lake.py | 3 +-
.../providers/microsoft/azure/hooks/msgraph.py | 10 +-
.../providers/microsoft/azure/hooks/powerbi.py | 2 +-
.../providers/microsoft/azure/hooks/synapse.py | 3 +-
.../providers/microsoft/azure/hooks/wasb.py | 3 +-
.../providers/microsoft/azure/operators/batch.py | 3 +-
.../azure/operators/container_instances.py | 3 +-
.../microsoft/azure/operators/data_factory.py | 9 +-
.../providers/microsoft/azure/operators/msgraph.py | 4 +-
.../providers/microsoft/azure/operators/powerbi.py | 3 +-
.../providers/microsoft/azure/operators/synapse.py | 9 +-
.../microsoft/azure/sensors/data_factory.py | 3 +-
.../providers/microsoft/azure/sensors/msgraph.py | 3 +-
.../providers/microsoft/azure/sensors/wasb.py | 3 +-
.../microsoft/azure/transfers/local_to_adls.py | 3 +-
.../microsoft/azure/transfers/sftp_to_wasb.py | 3 +-
.../tests/unit/microsoft/azure/hooks/test_adx.py | 2 +-
.../unit/microsoft/azure/hooks/test_cosmos.py | 2 +-
.../microsoft/azure/hooks/test_data_factory.py | 2 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 9 +-
.../unit/microsoft/azure/hooks/test_powerbi.py | 2 +-
.../unit/microsoft/azure/hooks/test_synapse.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_wasb.py | 2 +-
.../unit/microsoft/azure/operators/test_batch.py | 2 +-
.../azure/operators/test_container_instances.py | 2 +-
.../microsoft/azure/operators/test_data_factory.py | 2 +-
.../unit/microsoft/azure/operators/test_msgraph.py | 4 +-
.../unit/microsoft/azure/operators/test_powerbi.py | 3 +-
.../microsoft/azure/operators/test_powerbi_list.py | 3 +-
.../unit/microsoft/azure/operators/test_synapse.py | 2 +-
.../microsoft/azure/sensors/test_data_factory.py | 2 +-
.../unit/microsoft/azure/sensors/test_wasb.py | 2 +-
.../azure/transfers/test_local_to_adls.py | 2 +-
.../microsoft/azure/transfers/test_sftp_to_wasb.py | 2 +-
.../unit/microsoft/azure/triggers/test_msgraph.py | 2 +-
providers/microsoft/psrp/pyproject.toml | 2 +-
.../airflow/providers/microsoft/psrp/hooks/psrp.py | 3 +-
.../providers/microsoft/psrp/operators/psrp.py | 3 +-
.../tests/unit/microsoft/psrp/hooks/test_psrp.py | 2 +-
.../unit/microsoft/psrp/operators/test_psrp.py | 3 +-
providers/microsoft/winrm/pyproject.toml | 2 +-
.../providers/microsoft/winrm/hooks/winrm.py | 3 +-
.../providers/microsoft/winrm/operators/winrm.py | 3 +-
.../tests/unit/microsoft/winrm/hooks/test_winrm.py | 2 +-
.../unit/microsoft/winrm/operators/test_winrm.py | 2 +-
providers/neo4j/pyproject.toml | 2 +-
.../src/airflow/providers/neo4j/sensors/neo4j.py | 3 +-
.../neo4j/tests/unit/neo4j/sensors/test_neo4j.py | 3 +-
providers/openai/pyproject.toml | 2 +-
.../src/airflow/providers/openai/exceptions.py | 2 +-
.../tests/unit/openai/operators/test_openai.py | 3 +-
providers/openfaas/pyproject.toml | 2 +-
.../airflow/providers/openfaas/hooks/openfaas.py | 3 +-
.../tests/unit/openfaas/hooks/test_openfaas.py | 2 +-
providers/opensearch/pyproject.toml | 2 +-
.../providers/opensearch/hooks/opensearch.py | 3 +-
.../providers/opensearch/log/os_task_handler.py | 2 +-
.../providers/opensearch/operators/opensearch.py | 3 +-
.../tests/unit/opensearch/hooks/test_opensearch.py | 2 +-
providers/pagerduty/pyproject.toml | 2 +-
.../airflow/providers/pagerduty/hooks/pagerduty.py | 3 +-
.../providers/pagerduty/hooks/pagerduty_events.py | 3 +-
providers/postgres/pyproject.toml | 2 +-
.../airflow/providers/postgres/hooks/postgres.py | 7 +-
.../tests/unit/postgres/hooks/test_postgres.py | 3 +-
providers/presto/pyproject.toml | 2 +-
.../src/airflow/providers/presto/hooks/presto.py | 7 +-
.../presto/tests/unit/presto/hooks/test_presto.py | 2 +-
.../tests/unit/presto/hooks/test_presto_sql.py | 2 +-
providers/redis/pyproject.toml | 2 +-
providers/salesforce/pyproject.toml | 2 +-
.../tests/unit/salesforce/operators/test_bulk.py | 2 +-
providers/samba/pyproject.toml | 2 +-
.../providers/samba/transfers/gcs_to_samba.py | 3 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 2 +-
.../unit/samba/transfers/test_gcs_to_samba.py | 2 +-
providers/segment/pyproject.toml | 2 +-
.../src/airflow/providers/segment/hooks/segment.py | 3 +-
.../tests/unit/segment/hooks/test_segment.py | 2 +-
.../segment/operators/test_segment_track_event.py | 2 +-
providers/sftp/pyproject.toml | 2 +-
.../sftp/src/airflow/providers/sftp/exceptions.py | 2 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 7 +-
.../src/airflow/providers/sftp/operators/sftp.py | 3 +-
.../src/airflow/providers/sftp/sensors/sftp.py | 3 +-
.../src/airflow/providers/sftp/triggers/sftp.py | 2 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 2 +-
.../sftp/tests/unit/sftp/operators/test_sftp.py | 2 +-
.../sftp/tests/unit/sftp/sensors/test_sftp.py | 2 +-
.../sftp/tests/unit/sftp/triggers/test_sftp.py | 2 +-
providers/singularity/pyproject.toml | 2 +-
.../providers/singularity/operators/singularity.py | 3 +-
.../unit/singularity/operators/test_singularity.py | 2 +-
providers/slack/pyproject.toml | 2 +-
.../src/airflow/providers/slack/hooks/slack.py | 3 +-
.../airflow/providers/slack/hooks/slack_webhook.py | 3 +-
.../providers/slack/transfers/base_sql_to_slack.py | 3 +-
.../providers/slack/transfers/sql_to_slack.py | 4 +-
.../slack/transfers/sql_to_slack_webhook.py | 2 +-
.../slack/tests/unit/slack/hooks/test_slack.py | 2 +-
.../tests/unit/slack/hooks/test_slack_webhook.py | 2 +-
.../unit/slack/transfers/test_base_sql_to_slack.py | 2 +-
.../unit/slack/transfers/test_sql_to_slack.py | 2 +-
providers/smtp/pyproject.toml | 2 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 3 +-
.../src/airflow/providers/smtp/operators/smtp.py | 3 +-
providers/smtp/tests/unit/smtp/hooks/test_smtp.py | 2 +-
providers/snowflake/pyproject.toml | 2 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 4 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 3 +-
.../providers/snowflake/operators/snowflake.py | 2 +-
.../providers/snowflake/utils/openlineage.py | 88 +---
.../tests/unit/snowflake/hooks/test_snowflake.py | 2 +-
.../unit/snowflake/hooks/test_snowflake_sql_api.py | 3 +-
.../unit/snowflake/operators/test_snowflake.py | 2 +-
.../tests/unit/snowflake/utils/test_openlineage.py | 59 +--
providers/ssh/pyproject.toml | 2 +-
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 3 +-
.../ssh/src/airflow/providers/ssh/operators/ssh.py | 3 +-
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 2 +-
providers/ssh/tests/unit/ssh/operators/test_ssh.py | 8 +-
providers/standard/pyproject.toml | 2 +-
.../src/airflow/providers/standard/exceptions.py | 2 +-
.../airflow/providers/standard/operators/bash.py | 7 +-
.../providers/standard/operators/datetime.py | 3 +-
.../airflow/providers/standard/operators/python.py | 3 +-
.../providers/standard/operators/trigger_dagrun.py | 15 +-
.../providers/standard/sensors/filesystem.py | 3 +-
.../airflow/providers/standard/utils/skipmixin.py | 2 +-
.../tests/unit/standard/decorators/test_bash.py | 2 +-
.../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 | 6 +-
.../tests/unit/standard/decorators/test_sensor.py | 2 +-
.../unit/standard/decorators/test_short_circuit.py | 2 +-
.../tests/unit/standard/operators/test_bash.py | 2 +-
.../standard/operators/test_branch_operator.py | 2 +-
.../tests/unit/standard/operators/test_datetime.py | 16 +-
.../tests/unit/standard/operators/test_hitl.py | 2 +-
.../operators/test_latest_only_operator.py | 2 +-
.../tests/unit/standard/operators/test_python.py | 23 +-
.../unit/standard/operators/test_trigger_dagrun.py | 5 +-
.../tests/unit/standard/operators/test_weekday.py | 10 +-
.../tests/unit/standard/sensors/test_bash.py | 2 +-
.../standard/sensors/test_external_task_sensor.py | 7 +-
.../tests/unit/standard/sensors/test_filesystem.py | 2 +-
.../tests/unit/standard/sensors/test_python.py | 2 +-
.../tests/unit/standard/sensors/test_time.py | 2 +-
.../tests/unit/standard/sensors/test_time_delta.py | 3 +-
.../tests/unit/standard/sensors/test_weekday.py | 2 +-
.../tests/unit/standard/utils/test_skipmixin.py | 4 +-
providers/tableau/pyproject.toml | 2 +-
.../src/airflow/providers/tableau/hooks/tableau.py | 3 +-
.../airflow/providers/tableau/operators/tableau.py | 3 +-
.../tests/unit/tableau/hooks/test_tableau.py | 2 +-
.../tests/unit/tableau/operators/test_tableau.py | 2 +-
.../tests/unit/tableau/sensors/test_tableau.py | 2 +-
providers/telegram/pyproject.toml | 2 +-
.../airflow/providers/telegram/hooks/telegram.py | 3 +-
.../providers/telegram/operators/telegram.py | 3 +-
providers/teradata/pyproject.toml | 2 +-
.../src/airflow/providers/teradata/hooks/bteq.py | 2 +-
.../src/airflow/providers/teradata/hooks/ttu.py | 3 +-
.../teradata/operators/teradata_compute_cluster.py | 2 +-
.../teradata/triggers/teradata_compute_cluster.py | 2 +-
.../airflow/providers/teradata/utils/bteq_util.py | 2 +-
.../tests/unit/teradata/hooks/test_bteq.py | 2 +-
.../teradata/tests/unit/teradata/hooks/test_ttu.py | 2 +-
.../tests/unit/teradata/operators/test_teradata.py | 2 +-
.../operators/test_teradata_compute_cluster.py | 2 +-
.../tests/unit/teradata/utils/test_bteq_util.py | 2 +-
providers/trino/pyproject.toml | 2 +-
.../src/airflow/providers/trino/hooks/trino.py | 7 +-
.../trino/tests/unit/trino/hooks/test_trino.py | 2 +-
.../tests/unit/vertica/hooks/test_vertica_sql.py | 2 +-
.../system/weaviate/example_weaviate_cohere.py | 9 +
.../example_weaviate_dynamic_mapping_dag.py | 9 +
.../system/weaviate/example_weaviate_openai.py | 8 +
.../system/weaviate/example_weaviate_operator.py | 10 +
.../system/weaviate/example_weaviate_using_hook.py | 9 +
.../weaviate/example_weaviate_vectorizer_dag.py | 9 +
.../example_weaviate_without_vectorizer_dag.py | 9 +
providers/ydb/pyproject.toml | 2 +
.../ydb/src/airflow/providers/ydb/hooks/ydb.py | 2 +-
.../ydb/src/airflow/providers/ydb/operators/ydb.py | 2 +-
945 files changed, 1938 insertions(+), 2008 deletions(-)
create mode 100644
airflow-core/src/airflow/migrations/versions/0094_3_1_0_remove_team_id.py
