@@ -99,7 +99,7 @@ def make_engine_value_decoder(
9999 )
100100
101101 if src_type_kind == "Struct" :
102- return _make_engine_struct_value_decoder (
102+ return make_engine_struct_decoder (
103103 field_path ,
104104 src_type ["fields" ],
105105 dst_type_info ,
@@ -119,7 +119,7 @@ def make_engine_value_decoder(
119119 f"Type mismatch for `{ '' .join (field_path )} `: "
120120 f"declared `{ dst_type_info .core_type } `, a list type expected"
121121 )
122- row_decoder = _make_engine_struct_value_decoder (
122+ row_decoder = make_engine_struct_decoder (
123123 field_path ,
124124 engine_fields_schema ,
125125 analyze_type_info (dst_type_variant .elem_type ),
@@ -147,7 +147,7 @@ def decode(value: Any) -> Any | None:
147147 field_path , key_field_schema ["type" ], dst_type_variant .key_type
148148 )
149149 field_path .pop ()
150- value_decoder = _make_engine_struct_value_decoder (
150+ value_decoder = make_engine_struct_decoder (
151151 field_path ,
152152 engine_fields_schema [1 :],
153153 analyze_type_info (dst_type_variant .value_type ),
@@ -267,7 +267,7 @@ def decode_scalar(value: Any) -> Any | None:
267267 return lambda value : value
268268
269269
270- def _make_engine_struct_value_decoder (
270+ def make_engine_struct_decoder (
271271 field_path : list [str ],
272272 src_fields : list [dict [str , Any ]],
273273 dst_type_info : AnalyzedTypeInfo ,
0 commit comments