Fix mypy failure

airtai · Jun 10, 2024 · 3ab0457 · 3ab0457
1 parent 62f0ee7
commit 3ab0457
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/faststream/confluent/client.py b/faststream/confluent/client.py
@@ -117,7 +117,7 @@ def __init__(
     ) -> None:
         self.logger = logger
 
-        self.config = {} if config is None else config
+        self.config: Dict[str, Any] = {} if config is None else dict(config)
 
         if isinstance(bootstrap_servers, Iterable) and not isinstance(
             bootstrap_servers, str
@@ -317,7 +317,7 @@ def __init__(
     ) -> None:
         self.logger = logger
 
-        self.config = {} if config is None else config
+        self.config: Dict[str, Any] = {} if config is None else dict(config)
 
         if group_id is None:
             group_id = "confluent-kafka-consumer-group"