From 17d2303b8cf197ac97999dd7c51679eb59fe5430 Mon Sep 17 00:00:00 2001 From: Kumaran Rajendhiran Date: Fri, 24 May 2024 13:52:02 +0530 Subject: [PATCH] Use only logger in signature --- faststream/confluent/client.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/faststream/confluent/client.py b/faststream/confluent/client.py index 1e38085b4b..871a0a9fe7 100644 --- a/faststream/confluent/client.py +++ b/faststream/confluent/client.py @@ -3,7 +3,6 @@ from ssl import SSLContext from time import time from typing import ( - TYPE_CHECKING, Any, Callable, Dict, @@ -22,9 +21,6 @@ from faststream.log import logger from faststream.utils.functions import call_or_await -if TYPE_CHECKING: - from faststream.types import LoggerProto - _missing = object() @@ -110,7 +106,7 @@ def __init__( sasl_kerberos_service_name: str = "kafka", sasl_kerberos_domain_name: Optional[str] = None, sasl_oauth_token_provider: Optional[str] = None, - logger: Optional[Union["LoggerProto", logging.Logger]] = logger, + logger: Optional[logging.Logger] = logger, ) -> None: self.logger = logger if isinstance(bootstrap_servers, Iterable) and not isinstance( @@ -302,7 +298,7 @@ def __init__( sasl_kerberos_service_name: str = "kafka", sasl_kerberos_domain_name: Optional[str] = None, sasl_oauth_token_provider: Optional[str] = None, - logger: Optional[Union["LoggerProto", logging.Logger]] = logger, + logger: Optional[logging.Logger] = logger, ) -> None: self.logger = logger if group_id is None: