Skip to content

Commit fe8c810

Browse files
committed
Revert "Drop namespaces for wrapped records (#22)"
This reverts commit 60538cd.
1 parent 60538cd commit fe8c810

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/py_avro_schema/_schemas.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -321,9 +321,10 @@ def _wrap_as_record(self, inner_schema: JSONObj, names: NamesType) -> JSONType:
321321
Handles deduplication via ``names``.
322322
"""
323323
record_name = _avro_name_for_type(_type_from_annotated(self.py_type))
324-
if record_name in names:
325-
return record_name
326-
names.append(record_name)
324+
fullname = f"{self.namespace}.{record_name}" if self.namespace else record_name
325+
if fullname in names:
326+
return fullname
327+
names.append(fullname)
327328
record_schema = {
328329
"type": "record",
329330
"name": record_name,
@@ -332,6 +333,8 @@ def _wrap_as_record(self, inner_schema: JSONObj, names: NamesType) -> JSONType:
332333
{"name": REF_DATA_KEY, "type": inner_schema},
333334
],
334335
}
336+
if self.namespace:
337+
record_schema["namespace"] = self.namespace
335338
return record_schema
336339

337340

0 commit comments

Comments
 (0)