This is an automated email from the ASF dual-hosted git repository.

amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 3b4df0cd3d4 Use Label class from task sdk in providers (#49398)
3b4df0cd3d4 is described below

commit 3b4df0cd3d4920e09de8f5e66cc1d75e6c22e3ae
Author: Amogh Desai <amoghrajesh1...@gmail.com>
AuthorDate: Thu Apr 17 17:00:01 2025 +0530

    Use Label class from task sdk in providers (#49398)
---
 .../tests/system/amazon/aws/example_bedrock_retrieve_and_generate.py    | 2 +-
 providers/dbt/cloud/tests/system/dbt/cloud/example_dbt_cloud.py         | 2 +-
 .../azure/tests/system/microsoft/azure/example_adf_run_pipeline.py      | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/providers/amazon/tests/system/amazon/aws/example_bedrock_retrieve_and_generate.py
 
b/providers/amazon/tests/system/amazon/aws/example_bedrock_retrieve_and_generate.py
index 552d6efaffa..71a58caf7f9 100644
--- 
a/providers/amazon/tests/system/amazon/aws/example_bedrock_retrieve_and_generate.py
+++ 
b/providers/amazon/tests/system/amazon/aws/example_bedrock_retrieve_and_generate.py
@@ -58,7 +58,7 @@ from 
airflow.providers.amazon.aws.sensors.opensearch_serverless import (
 )
 from airflow.providers.amazon.aws.utils import get_botocore_version
 from airflow.providers.standard.operators.empty import EmptyOperator
-from airflow.utils.edgemodifier import Label
+from airflow.sdk import Label
 from airflow.utils.trigger_rule import TriggerRule
 
 from system.amazon.aws.utils import SystemTestContextBuilder
diff --git a/providers/dbt/cloud/tests/system/dbt/cloud/example_dbt_cloud.py 
b/providers/dbt/cloud/tests/system/dbt/cloud/example_dbt_cloud.py
index a9a2fb257ae..1c43ca0eabf 100644
--- a/providers/dbt/cloud/tests/system/dbt/cloud/example_dbt_cloud.py
+++ b/providers/dbt/cloud/tests/system/dbt/cloud/example_dbt_cloud.py
@@ -26,7 +26,7 @@ from airflow.providers.dbt.cloud.operators.dbt import (
 )
 from airflow.providers.dbt.cloud.sensors.dbt import DbtCloudJobRunSensor
 from airflow.providers.standard.operators.empty import EmptyOperator
-from airflow.utils.edgemodifier import Label
+from airflow.sdk import Label
 
 from tests_common.test_utils.system_tests import get_test_env_id
 
diff --git 
a/providers/microsoft/azure/tests/system/microsoft/azure/example_adf_run_pipeline.py
 
b/providers/microsoft/azure/tests/system/microsoft/azure/example_adf_run_pipeline.py
index ed95bdb0141..5bdc3ce5db2 100644
--- 
a/providers/microsoft/azure/tests/system/microsoft/azure/example_adf_run_pipeline.py
+++ 
b/providers/microsoft/azure/tests/system/microsoft/azure/example_adf_run_pipeline.py
@@ -28,7 +28,7 @@ from airflow.providers.microsoft.azure.sensors.data_factory 
import AzureDataFact
 # Ignore missing args provided by default_args
 # mypy: disable-error-code="call-arg"
 from airflow.providers.standard.operators.empty import EmptyOperator
-from airflow.utils.edgemodifier import Label
+from airflow.sdk import Label
 
 ENV_ID = os.environ.get("SYSTEM_TESTS_ENV_ID")
 DAG_ID = "example_adf_run_pipeline"

Reply via email to