Skip to content

Commit 1fc53b4

Browse files
authored
Minor fix to max_retries check (#1955)
1 parent 579696b commit 1fc53b4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/confluent_kafka/schema_registry/schema_registry_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ def __init__(self, conf: dict):
218218
self.max_retries = 3
219219
max_retries = conf_copy.pop('max.retries', None)
220220
if max_retries is not None:
221-
if not isinstance(timeout, (int, float)):
221+
if not isinstance(max_retries, (int, float)):
222222
raise TypeError("max.retries must be a number, not " + str(type(max_retries)))
223223
self.max_retries = max_retries
224224

0 commit comments

Comments
 (0)