Skip to content

Commit 7c8abdf

Browse files
committed
Fixing style check from master
1 parent b558c13 commit 7c8abdf

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/confluent_kafka/schema_registry/schema_registry_client.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -222,8 +222,7 @@ def remove_by_subject(self, subject_name):
222222
Args:
223223
subject_name (str): Subject name the schema is registered under.
224224
"""
225-
226-
225+
227226
with self.lock:
228227
if subject_name in self.subject_schemas:
229228
for schema in self.subject_schemas[subject_name]:
@@ -234,7 +233,6 @@ def remove_by_subject(self, subject_name):
234233

235234
del self.subject_schemas[subject_name]
236235

237-
238236
def get_schema(self, schema_id):
239237
"""
240238
Get the schema instance associated with schema_id from the cache.
@@ -566,9 +564,9 @@ def delete_subject(self, subject_name, permanent=False):
566564
if permanent:
567565
self._rest_client.delete('subjects/{}?permanent=true'
568566
.format(_urlencode(subject_name)))
569-
567+
570568
self._cache.remove_by_subject(subject_name)
571-
569+
572570
return list
573571

574572
def get_latest_version(self, subject_name):

0 commit comments

Comments
 (0)