Skip to content

Commit 2acaa79

Browse files
committed
fix wrong assigned variable in client logic
1 parent d5b90db commit 2acaa79

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/confluent_kafka/schema_registry/_async/schema_registry_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ async def send_request(
437437
" application/vnd.schemaregistry+json,"
438438
" application/json"}
439439

440-
body_str = None
440+
body_str: Optional[str] = None
441441
if body is not None:
442442
body_str = json.dumps(body)
443443
headers = {'Content-Length': str(len(body_str)),

src/confluent_kafka/schema_registry/_sync/schema_registry_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ def send_request(
437437
" application/vnd.schemaregistry+json,"
438438
" application/json"}
439439

440-
body_str = None
440+
body_str: Optional[str] = None
441441
if body is not None:
442442
body_str = json.dumps(body)
443443
headers = {'Content-Length': str(len(body_str)),

0 commit comments

Comments
 (0)