datacontract export --format avro - array

resovles #243

CHANGELOG.md

@@ -11,6 +11,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Introduced optional dependencies/extras for significantly faster installation times. (#213)
 - Added delta-lake as an additional optional dependency
 
+### Fixed
+- `datacontract export --format avro` fixed array structure (#243)
+
 ## [0.10.7] - 2024-05-31
 
 ### Added

datacontract/export/avro_converter.py

@@ -88,8 +88,7 @@ def to_avro_type(field: Field, field_name: str) -> str | dict:
     elif field.type in ["binary"]:
         return "bytes"
     elif field.type in ["array"]:
-        # TODO support array structs
-        return "array"
+        return {"type": "array", "items": to_avro_type(field.items, field_name)}
     elif field.type in ["null"]:
         return "null"
     else:

tests/fixtures/avro/export/datacontract.yaml

@@ -29,6 +29,10 @@ models:
         type: string
       orderunits:
         type: double
+      tags:
+        type: array
+        items:
+          type: string
       address:
         type: object
         fields:

tests/fixtures/avro/export/orders_with_datefields.avsc

@@ -38,6 +38,13 @@
       "name": "orderunits",
       "type": "double"
     },
+    {
+      "name": "tags",
+      "type": {
+        "type": "array",
+        "items": "string"
+      }
+    },
     {
       "name": "address",
       "type": {

tests/test_export_avro.py

@@ -27,7 +27,7 @@ def test_to_avro_schema():
     assert json.loads(result) == json.loads(expected_avro_schema)
 
 
-def test_to_avro_schema_with_logicalTypes():
+def test_to_avro_schema_with_logical_types():
     data_contract = DataContractSpecification.from_file("fixtures/avro/export/datacontract_logicalType.yaml")
     with open("fixtures/avro/export/datacontract_logicalType.avsc") as file:
         expected_avro_schema = file.read()