Skip to content

Commit 7e9376e

Browse files
rnpridgeonRyan P
authored and
Ryan P
committed
Make ProtobufSerializer.resolve_dependencies private
1 parent 8162c2d commit 7e9376e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

confluent_kafka/schema_registry/protobuf.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,7 @@ def _encode_uvarints(buf, ints):
254254
value >>= 7
255255
buf.write(_bytes(value))
256256

257-
def resolve_dependencies(self, ctx, file_desc):
257+
def _resolve_dependencies(self, ctx, file_desc):
258258
"""
259259
Resolves and optionally registers schema references recursively.
260260
@@ -266,7 +266,7 @@ def resolve_dependencies(self, ctx, file_desc):
266266
"""
267267
schema_refs = []
268268
for dep in file_desc.dependencies:
269-
dep_refs = self.resolve_dependencies(ctx, dep)
269+
dep_refs = self._resolve_dependencies(ctx, dep)
270270
subject = self._ref_reference_subject_func(ctx, dep)
271271
schema = Schema(_schema_to_str(dep),
272272
references=dep_refs,
@@ -313,7 +313,7 @@ def __call__(self, message_type, ctx):
313313
message_type.DESCRIPTOR.full_name)
314314

315315
if subject not in self._known_subjects:
316-
self._schema.references = self.resolve_dependencies(
316+
self._schema.references = self._resolve_dependencies(
317317
ctx, message_type.DESCRIPTOR.file)
318318

319319
if self._auto_register:

0 commit comments

Comments
 (0)