This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-9a0a07653c
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard dc1d8a2af5a Bump the core-ui-package-updates group across 1 directory
with 11 updates
add 1ab242a6be4 Mock `time.sleep` in tableau test (#52647)
add 865c2f9c856 Provider Migration: Update Redis for Airflow 3.0
compatibility (#52597)
add 040b782663f Replace airflow.models.baseoperator to airflow.sdk for
Microsoft Winrm (#52657)
add 09438ff6c6a Add tracking of triggering user to Dag runs (#51738)
add d3ca35d6c60 Replace airflow.models.baseoperator to airflow.sdk for
Microsoft PSRP (#52654)
add 05df9925bef Provider Migration: Update Snowflake provider for Airflow
3.0 compatibility (#52629)
add 3bf19a7d95c feat(airflowctl): Add Connections Import/Export from/to
file (#52584)
add cc157c7ef6d Remove more usages of legacy grid data endpoint (#52302)
add 81b804fa4dd Fix typoed parameter passign in calling a method in dev
report (#52659)
add 948d7d728aa Replace models.BaseOperator to Task SDK one for ftp
(#52338)
add c64daf1e050 Add support for `PackageIndex` connections in
`PythonVirtualenvOperator` (#52288)
add 3169e273b6f Update Kubernetes provider for Airflow 3.0 compatibility
(#52664)
add 9f975841068 Replace `models.BaseOperator` to Task SDK one for Amazon
Provider (#52667)
add 7adb432f116 Provider Migration: Update azure for Airflow 3.0
compatibility (#52618)
add cf43b561c0d Provider Migration: Update elasticsearch for Airflow 3.0
compatibility (#52628)
add 09a58cc407f Remove language flags (#52671)
add ea5d5c3ea3c Move `BaseHook` implementation to task SDK (#51873)
add b18c2689aae Enable LDAP users to generate an Airflow token with
`FabAuthManager` (#52295)
add e55464a4fa5 fix indent issue (#51701)
add d3bddfd5284 Add back dag parsing pre-import optimization (#50371)
add 2d2d1cbf291 bugfix: removed cache for proxycommand in SFTPHook (#52641)
add bb93415b6e8 Fix connection retrieval in triggerer for schema field,
use by_alias=True for ConnectionResult (#52673)
add 953378b044e Fix missing translations (#52670)
add f51f472ec49 Add http-only warning in documentation (#52631)
add e2be640cd6b Refactor Databricks hook to use HTTP method constants and
auto-prepend api/ to endpoint paths (#52385)
add 6bb9a0e406d i18n(Ko): add missing translation (#52669)
add e0bf03c3d33 [AIP-68] Support pluginv2 views (#52582)
add 34b43338317 Doc: Update version_added field for
`socket_cleanup_timeout` (#52705)
add 906da034029 Move costraint check to breeze (#52696)
add 7d47e939dc4 Add missing translations in Polish (#52701)
add b0009285fc5 Add warning in changelog: use OdbcHook for ODBC drivers
instead of MsSqlHook (#52646)
add 64a5919b992 Ensure trigger kwargs are properly deserialized during
trigger execution (#52693)
add eceecff8f92 Improve plugins menu items (#52719)
add aaf165c5f05 Update plugin documentation (#52695)
add cdf3e322748 Bump the core-ui-package-updates group across 1 directory
with 11 updates
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 (dc1d8a2af5a)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/core-ui-package-updates-9a0a07653c
(cdf3e322748)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/finalize-tests.yml | 4 +-
.../docs/administration-and-deployment/plugins.rst | 9 +-
airflow-core/docs/howto/run-behind-proxy.rst | 3 +
airflow-core/docs/img/airflow_erd.sha256 | 2 +-
airflow-core/docs/img/airflow_erd.svg | 732 +++++++++++----------
.../docs/installation/upgrading_to_airflow3.rst | 3 +-
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/docs/public-airflow-interface.rst | 2 +-
.../src/airflow/api/client/local_client.py | 10 +-
airflow-core/src/airflow/api/common/trigger_dag.py | 10 +-
.../auth/managers/simple/ui/package-lock.json | 18 +-
.../auth/managers/simple/ui/package.json | 4 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 224 ++++---
.../api_fastapi/core_api/datamodels/dag_run.py | 1 +
.../api_fastapi/core_api/datamodels/ui/grid.py | 3 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 30 +
.../core_api/openapi/v2-rest-api-generated.yaml | 6 +
.../api_fastapi/core_api/routes/public/assets.py | 3 +
.../core_api/routes/public/backfills.py | 4 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 1 +
.../airflow/api_fastapi/core_api/routes/ui/grid.py | 40 +-
.../api_fastapi/core_api/services/ui/grid.py | 44 +-
.../src/airflow/cli/commands/asset_command.py | 11 +-
.../src/airflow/cli/commands/backfill_command.py | 10 +
.../src/airflow/cli/commands/connection_command.py | 3 +-
.../src/airflow/cli/commands/dag_command.py | 9 +-
.../src/airflow/cli/commands/task_command.py | 10 +-
.../src/airflow/config_templates/config.yml | 22 +-
airflow-core/src/airflow/configuration.py | 1 +
.../src/airflow/dag_processing/processor.py | 28 +
airflow-core/src/airflow/hooks/__init__.py | 3 +
airflow-core/src/airflow/hooks/base.py | 70 +-
.../src/airflow/jobs/triggerer_job_runner.py | 15 +-
airflow-core/src/airflow/lineage/hook.py | 3 +-
...> 0074_3_1_0_add_triggering_user_to_dag_run.py} | 32 +-
airflow-core/src/airflow/models/backfill.py | 10 +
airflow-core/src/airflow/models/dag.py | 15 +-
airflow-core/src/airflow/models/dagrun.py | 6 +
airflow-core/src/airflow/models/mappedoperator.py | 2 +-
airflow-core/src/airflow/providers_manager.py | 2 +-
.../airflow/serialization/serialized_objects.py | 25 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 56 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 6 +
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 14 +-
.../airflow/ui/public/i18n/locales/de/common.json | 3 +-
.../src/airflow/ui/public/i18n/locales/de/dag.json | 14 +-
.../airflow/ui/public/i18n/locales/en/common.json | 5 +-
.../ui/public/i18n/locales/en/components.json | 3 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 21 +-
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 14 +-
.../src/airflow/ui/public/i18n/locales/he/dag.json | 14 +-
.../airflow/ui/public/i18n/locales/ko/common.json | 3 +-
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 14 +-
.../airflow/ui/public/i18n/locales/pl/common.json | 4 +-
.../ui/public/i18n/locales/pl/components.json | 3 +
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 21 +-
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 14 +-
.../src/components/DagActions/RunBackfillForm.tsx | 2 +-
.../ui/src/constants/reprocessBehaviourParams.ts | 6 +-
airflow-core/src/airflow/ui/src/i18n/config.ts | 18 +-
.../airflow/ui/src/layouts/Details/Grid/Bar.tsx | 2 +-
.../ui/src/layouts/Nav/LanguageSelector.tsx | 2 +-
.../airflow/ui/src/layouts/Nav/PluginMenuItem.tsx | 28 +-
.../src/airflow/ui/src/layouts/Nav/PluginMenus.tsx | 33 +-
.../ui/src/pages/Dag/Backfills/Backfills.tsx | 10 +-
.../pages/GroupTaskInstance/GroupTaskInstance.tsx | 55 +-
.../ui/src/pages/GroupTaskInstance/Header.tsx | 31 +-
airflow-core/src/airflow/ui/src/pages/Iframe.tsx | 11 +-
.../ui/src/pages/MappedTaskInstance/Header.tsx | 35 +-
.../MappedTaskInstance/MappedTaskInstance.tsx | 54 +-
.../src/airflow/ui/src/pages/Run/Details.tsx | 4 +
.../src/pages/TaskInstance/Logs/TaskLogHeader.tsx | 16 +-
.../airflow/ui/src/queries/useGridTISummaries.ts | 20 +-
airflow-core/src/airflow/ui/src/utils/logs.ts | 12 +-
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/email.py | 2 +-
airflow-core/tests/unit/always/test_connection.py | 14 +-
.../tests/unit/always/test_example_dags.py | 2 +-
.../unit/api_fastapi/common/test_exceptions.py | 6 +-
.../core_api/routes/public/test_assets.py | 1 +
.../core_api/routes/public/test_backfills.py | 1 +
.../core_api/routes/public/test_dag_run.py | 4 +
.../api_fastapi/core_api/routes/ui/test_grid.py | 47 +-
.../tests/unit/cli/commands/test_asset_command.py | 1 +
.../unit/cli/commands/test_backfill_command.py | 1 +
.../unit/cli/commands/test_connection_command.py | 5 +-
.../cli/commands/test_rotate_fernet_key_command.py | 28 +-
.../tests/unit/dag_processing/test_processor.py | 91 ++-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 7 +
airflow-core/tests/unit/jobs/test_triggerer_job.py | 70 +-
airflow-core/tests/unit/lineage/test_hook.py | 2 +-
airflow-core/tests/unit/models/test_backfill.py | 9 +
.../unit/serialization/test_dag_serialization.py | 3 +-
airflow-ctl/docs/images/command_hashes.txt | 2 +-
airflow-ctl/docs/images/output_connections.svg | 92 +--
.../src/airflowctl/api/datamodels/generated.py | 1 +
airflow-ctl/src/airflowctl/ctl/cli_config.py | 72 +-
.../airflowctl/ctl/commands/connection_command.py | 93 +++
.../ctl/commands/test_connections_command.py | 160 +++++
dev/breeze/doc/09_release_management_tasks.rst | 19 +
.../doc/images/output_release-management.svg | 20 +-
.../doc/images/output_release-management.txt | 2 +-
...elease-management_constraints-version-check.svg | 172 +++++
...elease-management_constraints-version-check.txt | 1 +
.../output_setup_check-all-params-in-groups.svg | 62 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 4 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../commands/release_management_commands.py | 67 +-
.../commands/release_management_commands_config.py | 25 +
dev/breeze/src/airflow_breeze/utils/cdxgen.py | 10 +-
.../utils/constraints_version_check.py} | 486 ++++++--------
dev/breeze/src/airflow_breeze/utils/github.py | 22 +-
.../src/tests_common/test_utils/common_sql.py | 2 +-
.../src/airflow/providers/airbyte/hooks/airbyte.py | 6 +-
.../alibaba/cloud/hooks/analyticdb_spark.py | 6 +-
.../providers/alibaba/cloud/hooks/base_alibaba.py | 5 +-
.../airflow/providers/alibaba/cloud/hooks/oss.py | 11 +-
.../providers/amazon/aws/hooks/athena_sql.py | 5 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 11 +-
.../airflow/providers/amazon/aws/hooks/chime.py | 4 +
.../amazon/aws/hooks/sagemaker_unified_studio.py | 6 +-
.../airflow/providers/amazon/aws/links/base_aws.py | 12 +-
.../providers/amazon/aws/operators/base_aws.py | 2 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 2 +-
.../amazon/aws/operators/redshift_data.py | 2 +-
.../aws/operators/sagemaker_unified_studio.py | 2 +-
.../providers/amazon/aws/sensors/base_aws.py | 8 +-
.../amazon/aws/sensors/sagemaker_unified_studio.py | 7 +-
.../amazon/aws/transfers/azure_blob_to_s3.py | 2 +-
.../airflow/providers/amazon/aws/transfers/base.py | 2 +-
.../providers/amazon/aws/transfers/exasol_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/ftp_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/gcs_to_s3.py | 2 +-
.../amazon/aws/transfers/glacier_to_gcs.py | 2 +-
.../amazon/aws/transfers/google_api_to_s3.py | 2 +-
.../amazon/aws/transfers/hive_to_dynamodb.py | 2 +-
.../providers/amazon/aws/transfers/http_to_s3.py | 2 +-
.../amazon/aws/transfers/imap_attachment_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/local_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/mongo_to_s3.py | 2 +-
.../amazon/aws/transfers/redshift_to_s3.py | 2 +-
.../amazon/aws/transfers/s3_to_dynamodb.py | 2 +-
.../providers/amazon/aws/transfers/s3_to_ftp.py | 2 +-
.../amazon/aws/transfers/s3_to_redshift.py | 2 +-
.../providers/amazon/aws/transfers/s3_to_sftp.py | 2 +-
.../providers/amazon/aws/transfers/s3_to_sql.py | 8 +-
.../amazon/aws/transfers/salesforce_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/sftp_to_s3.py | 2 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 8 +-
.../amazon/aws/utils/connection_wrapper.py | 5 +-
.../src/airflow/providers/amazon/version_compat.py | 10 +
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 14 +-
.../tests/unit/amazon/aws/links/test_base_aws.py | 42 +-
.../unit/amazon/aws/operators/test_base_aws.py | 6 +-
.../tests/unit/amazon/aws/operators/test_ecs.py | 56 +-
.../tests/unit/amazon/aws/sensors/test_base_aws.py | 6 +-
.../airflow/providers/apache/beam/hooks/beam.py | 6 +-
.../providers/apache/cassandra/hooks/cassandra.py | 7 +-
.../airflow/providers/apache/drill/hooks/drill.py | 2 +-
.../airflow/providers/apache/druid/hooks/druid.py | 12 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 16 +-
.../airflow/providers/apache/hive/hooks/hive.py | 12 +-
.../providers/apache/iceberg/hooks/iceberg.py | 9 +-
.../airflow/providers/apache/kafka/hooks/base.py | 5 +-
.../tests/unit/apache/kafka/hooks/test_base.py | 20 +-
.../airflow/providers/apache/kylin/hooks/kylin.py | 6 +-
.../airflow/providers/apache/livy/hooks/livy.py | 2 +-
.../src/airflow/providers/apache/pig/hooks/pig.py | 6 +-
.../airflow/providers/apache/pinot/hooks/pinot.py | 17 +-
.../providers/apache/spark/decorators/pyspark.py | 6 +-
.../providers/apache/spark/hooks/spark_connect.py | 15 +-
.../providers/apache/spark/hooks/spark_jdbc.py | 18 +-
.../providers/apache/spark/hooks/spark_sql.py | 11 +-
.../providers/apache/spark/hooks/spark_submit.py | 6 +-
.../providers/apache/tinkerpop/hooks/gremlin.py | 12 +-
.../src/airflow/providers/apprise/hooks/apprise.py | 5 +-
.../airflow/providers/arangodb/hooks/arangodb.py | 8 +-
.../src/airflow/providers/asana/hooks/asana.py | 5 +-
.../airflow/providers/atlassian/jira/hooks/jira.py | 10 +-
.../airflow/providers/cloudant/hooks/cloudant.py | 19 +-
.../cncf/kubernetes/decorators/kubernetes.py | 16 +-
.../cncf/kubernetes/decorators/kubernetes_cmd.py | 15 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 8 +-
.../providers/cncf/kubernetes/operators/job.py | 2 +-
.../providers/cncf/kubernetes/operators/kueue.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 2 +-
.../cncf/kubernetes/operators/resource.py | 2 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 7 +-
.../providers/cncf/kubernetes/version_compat.py | 27 +
.../src/airflow/providers/cohere/hooks/cohere.py | 6 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 17 +-
.../common/sql/operators/generic_transfer.py | 6 +-
.../airflow/providers/common/sql/operators/sql.py | 6 +-
.../airflow/providers/common/sql/sensors/sql.py | 7 +-
.../airflow/providers/common/sql/triggers/sql.py | 6 +-
.../sql/tests/unit/common/sql/hooks/test_dbapi.py | 6 +-
.../common/sql/operators/test_generic_transfer.py | 17 +-
.../tests/unit/common/sql/operators/test_sql.py | 13 +-
.../sql/tests/unit/common/sql/triggers/test_sql.py | 11 +-
.../providers/databricks/hooks/databricks.py | 66 +-
.../providers/databricks/hooks/databricks_base.py | 16 +-
.../tests/unit/databricks/hooks/test_databricks.py | 10 +-
.../src/airflow/providers/datadog/hooks/datadog.py | 6 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 2 +-
.../src/airflow/providers/docker/hooks/docker.py | 8 +-
providers/docker/tests/conftest.py | 12 +-
.../edge3/example_dags/integration_test.py | 6 +-
.../providers/edge3/example_dags/win_test.py | 6 +-
.../providers/elasticsearch/hooks/elasticsearch.py | 16 +-
.../providers/elasticsearch/log/es_task_handler.py | 9 +-
.../providers/elasticsearch/version_compat.py | 7 +
providers/fab/docs/auth-manager/token.rst | 3 +
.../fab/auth_manager/api_fastapi/services/login.py | 25 +-
.../fab/auth_manager/security_manager/override.py | 12 +-
.../src/airflow/providers/fab}/version_compat.py | 2 +-
.../providers/fab/www/extensions/init_views.py | 14 +-
.../api_fastapi/services/test_login.py | 121 ++--
providers/fab/www-hash.txt | 2 +-
.../airflow/providers/facebook/ads/hooks/ads.py | 6 +-
.../tests/unit/facebook/ads/hooks/test_ads.py | 14 +-
.../ftp/src/airflow/providers/ftp/hooks/ftp.py | 13 +-
.../ftp/src/airflow/providers/ftp/operators/ftp.py | 2 +-
.../src/airflow/providers/ftp/version_compat.py | 7 +
.../git/src/airflow/providers/git/hooks/git.py | 6 +-
.../src/airflow/providers/github/hooks/github.py | 6 +-
.../src/airflow/providers/google/ads/hooks/ads.py | 6 +-
.../providers/google/cloud/hooks/cloud_sql.py | 12 +-
.../providers/google/cloud/hooks/dataprep.py | 5 +-
.../airflow/providers/google/cloud/hooks/looker.py | 6 +-
.../providers/google/cloud/operators/cloud_sql.py | 6 +-
.../providers/google/common/hooks/base_google.py | 6 +-
.../providers/google/leveldb/hooks/leveldb.py | 6 +-
.../google/tests/unit/google/ads/hooks/test_ads.py | 14 +-
.../tests/unit/google/cloud/hooks/test_alloy_db.py | 11 +-
.../tests/unit/google/cloud/hooks/test_dataprep.py | 13 +-
.../tests/unit/google/cloud/hooks/test_looker.py | 11 +-
.../unit/google/cloud/operators/test_cloud_sql.py | 13 +-
.../tests/unit/google/suite/hooks/test_drive.py | 12 +-
.../grpc/src/airflow/providers/grpc/hooks/grpc.py | 8 +-
providers/grpc/tests/unit/grpc/hooks/test_grpc.py | 34 +-
.../src/airflow/providers/hashicorp/hooks/vault.py | 6 +-
.../http/src/airflow/providers/http/hooks/http.py | 14 +-
.../src/airflow/providers/http/operators/http.py | 6 +-
.../imap/src/airflow/providers/imap/hooks/imap.py | 11 +-
.../airflow/providers/influxdb/hooks/influxdb.py | 7 +-
.../jdbc/src/airflow/providers/jdbc/hooks/jdbc.py | 16 +-
.../src/airflow/providers/jenkins/hooks/jenkins.py | 5 +-
.../tests/unit/jenkins/hooks/test_jenkins.py | 16 +-
.../airflow/providers/microsoft/azure/fs/adls.py | 6 +-
.../airflow/providers/microsoft/azure/hooks/adx.py | 14 +-
.../airflow/providers/microsoft/azure/hooks/asb.py | 6 +-
.../providers/microsoft/azure/hooks/base_azure.py | 6 +-
.../providers/microsoft/azure/hooks/batch.py | 6 +-
.../microsoft/azure/hooks/container_instance.py | 4 +-
.../microsoft/azure/hooks/container_registry.py | 12 +-
.../microsoft/azure/hooks/container_volume.py | 10 +-
.../providers/microsoft/azure/hooks/cosmos.py | 13 +-
.../microsoft/azure/hooks/data_factory.py | 6 +-
.../providers/microsoft/azure/hooks/data_lake.py | 13 +-
.../providers/microsoft/azure/hooks/fileshare.py | 6 +-
.../providers/microsoft/azure/hooks/msgraph.py | 8 +-
.../providers/microsoft/azure/hooks/synapse.py | 6 +-
.../providers/microsoft/azure/hooks/wasb.py | 15 +-
.../providers/microsoft/azure/operators/adls.py | 2 +-
.../providers/microsoft/azure/operators/adx.py | 2 +-
.../providers/microsoft/azure/operators/asb.py | 2 +-
.../providers/microsoft/azure/operators/batch.py | 2 +-
.../azure/operators/container_instances.py | 2 +-
.../providers/microsoft/azure/operators/cosmos.py | 2 +-
.../microsoft/azure/operators/data_factory.py | 8 +-
.../providers/microsoft/azure/operators/msgraph.py | 4 +-
.../providers/microsoft/azure/operators/powerbi.py | 14 +-
.../providers/microsoft/azure/operators/synapse.py | 8 +-
.../microsoft/azure/operators/wasb_delete_blob.py | 2 +-
.../microsoft/azure/transfers/local_to_adls.py | 2 +-
.../microsoft/azure/transfers/local_to_wasb.py | 2 +-
.../azure/transfers/oracle_to_azure_data_lake.py | 2 +-
.../microsoft/azure/transfers/s3_to_wasb.py | 2 +-
.../microsoft/azure/transfers/sftp_to_wasb.py | 3 +
.../providers/microsoft/azure/version_compat.py | 17 +
.../azure/tests/unit/microsoft/azure/base.py | 12 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 48 +-
.../unit/microsoft/azure/operators/test_powerbi.py | 13 +-
.../microsoft/azure/operators/test_powerbi_list.py | 13 +-
.../unit/microsoft/azure/triggers/test_msgraph.py | 12 +-
.../unit/microsoft/azure/triggers/test_powerbi.py | 11 +-
providers/microsoft/mssql/docs/changelog.rst | 3 +
.../providers/microsoft/mssql/hooks/mssql.py | 4 +-
.../airflow/providers/microsoft/psrp/hooks/psrp.py | 9 +-
.../providers/microsoft/psrp/operators/psrp.py | 2 +-
.../providers/microsoft/psrp}/version_compat.py | 0
.../unit/microsoft/psrp/operators/test_psrp.py | 2 +-
.../providers/microsoft/winrm/hooks/winrm.py | 6 +-
.../providers/microsoft/winrm/operators/winrm.py | 2 +-
.../providers/microsoft/winrm}/version_compat.py | 0
.../src/airflow/providers/mongo/hooks/mongo.py | 8 +-
.../src/airflow/providers/mysql/hooks/mysql.py | 4 +-
.../src/airflow/providers/neo4j/hooks/neo4j.py | 9 +-
.../src/airflow/providers/openai/hooks/openai.py | 6 +-
.../airflow/providers/openfaas/hooks/openfaas.py | 6 +-
.../tests/unit/openfaas/hooks/test_openfaas.py | 6 +-
.../src/airflow/providers/openlineage/sqlparser.py | 2 +-
.../src/airflow/providers/openlineage/utils/sql.py | 2 +-
.../providers/opensearch/hooks/opensearch.py | 6 +-
.../opensearch/tests/unit/opensearch/conftest.py | 6 +-
.../tests/unit/opensearch/hooks/test_opensearch.py | 11 +-
.../airflow/providers/opsgenie/hooks/opsgenie.py | 9 +-
.../src/airflow/providers/oracle/hooks/oracle.py | 11 +-
.../airflow/providers/pagerduty/hooks/pagerduty.py | 6 +-
.../providers/pagerduty/hooks/pagerduty_events.py | 6 +-
.../airflow/providers/papermill/hooks/kernel.py | 8 +-
.../airflow/providers/pinecone/hooks/pinecone.py | 7 +-
.../airflow/providers/postgres/hooks/postgres.py | 16 +-
.../src/airflow/providers/qdrant/hooks/qdrant.py | 5 +-
.../src/airflow/providers/redis/hooks/redis.py | 5 +-
.../providers/redis/operators/redis_publish.py | 2 +-
.../airflow/providers/redis/sensors/redis_key.py | 7 +-
.../providers/redis/sensors/redis_pub_sub.py | 7 +-
.../src/airflow/providers/redis/version_compat.py | 8 +
.../providers/salesforce/hooks/salesforce.py | 5 +-
.../src/airflow/providers/samba/hooks/samba.py | 5 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 15 +-
.../src/airflow/providers/segment/hooks/segment.py | 6 +-
.../airflow/providers/sendgrid/utils/emailer.py | 5 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 16 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 42 ++
.../src/airflow/providers/slack/hooks/slack.py | 6 +-
.../airflow/providers/slack/hooks/slack_webhook.py | 6 +-
.../providers/slack/transfers/base_sql_to_slack.py | 6 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 21 +-
.../snowflake/transfers/copy_into_snowflake.py | 2 +-
.../airflow/providers/snowflake/version_compat.py | 10 +
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 9 +-
providers/standard/docs/operators/python.rst | 3 +
.../airflow/providers/standard/hooks/filesystem.py | 5 +-
.../providers/standard/hooks/package_index.py | 5 +-
.../airflow/providers/standard/hooks/subprocess.py | 5 +-
.../airflow/providers/standard/operators/python.py | 25 +-
.../tests/unit/standard/operators/test_python.py | 32 +
.../src/airflow/providers/tableau/hooks/tableau.py | 12 +-
.../tests/unit/tableau/hooks/test_tableau.py | 3 +-
.../airflow/providers/telegram/hooks/telegram.py | 6 +-
.../airflow/providers/teradata/hooks/teradata.py | 7 +-
.../src/airflow/providers/teradata/hooks/ttu.py | 6 +-
.../src/airflow/providers/vertica/hooks/vertica.py | 2 +-
.../airflow/providers/weaviate/hooks/weaviate.py | 9 +-
.../src/airflow/providers/yandex/hooks/yandex.py | 6 +-
.../tests/unit/yandex/hooks/test_dataproc.py | 11 +-
.../yandex/tests/unit/yandex/hooks/test_yandex.py | 21 +-
.../yandex/tests/unit/yandex/hooks/test_yq.py | 11 +-
.../tests/unit/yandex/operators/test_dataproc.py | 22 +-
.../yandex/tests/unit/yandex/operators/test_yq.py | 12 +-
.../ydb/src/airflow/providers/ydb/hooks/ydb.py | 8 +-
.../src/airflow/providers/ydb/utils/credentials.py | 5 +-
providers/ydb/tests/unit/ydb/hooks/test_ydb.py | 12 +-
providers/ydb/tests/unit/ydb/operators/test_ydb.py | 12 +-
.../src/airflow/providers/zendesk/hooks/zendesk.py | 20 +-
scripts/in_container/verify_providers.py | 2 +-
scripts/tools/list-integrations.py | 2 +-
task-sdk/docs/api.rst | 2 +
task-sdk/src/airflow/sdk/__init__.py | 3 +
task-sdk/src/airflow/sdk/__init__.pyi | 2 +
task-sdk/src/airflow/sdk/bases/hook.py | 96 +++
task-sdk/src/airflow/sdk/definitions/dag.py | 1 +
.../tests/task_sdk/bases/test_hook.py | 9 +-
366 files changed, 3992 insertions(+), 1974 deletions(-)
copy
airflow-core/src/airflow/migrations/versions/{0037_3_0_0_add_backfill_to_dag_run_model.py
=> 0074_3_1_0_add_triggering_user_to_dag_run.py} (60%)
create mode 100644
airflow-ctl/src/airflowctl/ctl/commands/connection_command.py
create mode 100644
airflow-ctl/tests/airflow_ctl/ctl/commands/test_connections_command.py
create mode 100644
dev/breeze/doc/images/output_release-management_constraints-version-check.svg
create mode 100644
dev/breeze/doc/images/output_release-management_constraints-version-check.txt
rename dev/{constraints-updated-version-check.py =>
breeze/src/airflow_breeze/utils/constraints_version_check.py} (50%)
copy providers/{apache/impala/src/airflow/providers/apache/impala =>
fab/src/airflow/providers/fab}/version_compat.py (95%)
copy providers/{papermill/src/airflow/providers/papermill =>
microsoft/psrp/src/airflow/providers/microsoft/psrp}/version_compat.py (100%)
copy providers/{papermill/src/airflow/providers/papermill =>
microsoft/winrm/src/airflow/providers/microsoft/winrm}/version_compat.py (100%)
create mode 100644 task-sdk/src/airflow/sdk/bases/hook.py
rename airflow-core/tests/unit/hooks/test_base.py =>
task-sdk/tests/task_sdk/bases/test_hook.py (90%)
