From d652750a26d5af65739c479260fb6a1828eb940a Mon Sep 17 00:00:00 2001 From: vincbeck Date: Tue, 5 Aug 2025 10:30:47 -0400 Subject: [PATCH] Fix `importskip` statements in tests --- providers/amazon/tests/unit/amazon/aws/queues/test_sqs.py | 2 +- .../apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/providers/amazon/tests/unit/amazon/aws/queues/test_sqs.py b/providers/amazon/tests/unit/amazon/aws/queues/test_sqs.py index 95c28392473e5..457c61c7d87fa 100644 --- a/providers/amazon/tests/unit/amazon/aws/queues/test_sqs.py +++ b/providers/amazon/tests/unit/amazon/aws/queues/test_sqs.py @@ -20,7 +20,7 @@ from airflow.providers.amazon.aws.triggers.sqs import SqsSensorTrigger -pytest.importorskip("airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider") +pytest.importorskip("airflow.providers.common.messaging.providers.base_provider") def test_message_sqs_queue_create(): diff --git a/providers/apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py b/providers/apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py index 567c2f171026a..0edd823d74187 100644 --- a/providers/apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py +++ b/providers/apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py @@ -20,7 +20,7 @@ from airflow.providers.apache.kafka.triggers.await_message import AwaitMessageTrigger -pytest.importorskip("airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider") +pytest.importorskip("airflow.providers.common.messaging.providers.base_provider") MOCK_KAFKA_TRIGGER_APPLY_FUNCTION = "mock_kafka_trigger_apply_function"