From 7682ae4430ec1adad89772e3df692ca8856bb649 Mon Sep 17 00:00:00 2001 From: David Gardner Date: Thu, 5 Oct 2023 07:10:14 -0700 Subject: [PATCH] Fix linting errors --- tests/test_kafka_source_stage_pipe.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/tests/test_kafka_source_stage_pipe.py b/tests/test_kafka_source_stage_pipe.py index eb27867e28..ea45cca35c 100644 --- a/tests/test_kafka_source_stage_pipe.py +++ b/tests/test_kafka_source_stage_pipe.py @@ -15,7 +15,6 @@ # limitations under the License. import os -import time import typing import pandas as pd @@ -38,9 +37,6 @@ if (typing.TYPE_CHECKING): from kafka import KafkaConsumer -if (typing.TYPE_CHECKING): - from kafka import KafkaConsumer - @pytest.mark.kafka def test_kafka_source_stage_pipe(config, kafka_bootstrap_servers: str, kafka_topics: typing.Tuple[str, str]) -> None: