Skip to content

Commit

Permalink
Fixed style check (#1829)
Browse files Browse the repository at this point in the history
  • Loading branch information
pranavrth authored Oct 9, 2024
1 parent c83d3da commit a356f2a
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions src/confluent_kafka/schema_registry/schema_registry_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -222,8 +222,7 @@ def remove_by_subject(self, subject_name):
Args:
subject_name (str): Subject name the schema is registered under.
"""



with self.lock:
if subject_name in self.subject_schemas:
for schema in self.subject_schemas[subject_name]:
Expand All @@ -234,7 +233,6 @@ def remove_by_subject(self, subject_name):

del self.subject_schemas[subject_name]


def get_schema(self, schema_id):
"""
Get the schema instance associated with schema_id from the cache.
Expand Down Expand Up @@ -566,9 +564,9 @@ def delete_subject(self, subject_name, permanent=False):
if permanent:
self._rest_client.delete('subjects/{}?permanent=true'
.format(_urlencode(subject_name)))

self._cache.remove_by_subject(subject_name)

return list

def get_latest_version(self, subject_name):
Expand Down

0 comments on commit a356f2a

Please sign in to comment.