@@ -176,7 +176,8 @@ def validate_ex(expected_schema, # type: Schema
176
176
strict = strict ,
177
177
foreign_properties = foreign_properties ,
178
178
raise_ex = raise_ex ,
179
- strict_foreign_properties = strict_foreign_properties ):
179
+ strict_foreign_properties = strict_foreign_properties ,
180
+ logger = logger ):
180
181
return False
181
182
except ValidationException as v :
182
183
if raise_ex :
@@ -194,7 +195,8 @@ def validate_ex(expected_schema, # type: Schema
194
195
elif isinstance (expected_schema , avro .schema .UnionSchema ):
195
196
for s in expected_schema .schemas :
196
197
if validate_ex (s , datum , identifiers , strict = strict , raise_ex = False ,
197
- strict_foreign_properties = strict_foreign_properties ):
198
+ strict_foreign_properties = strict_foreign_properties ,
199
+ logger = logger ):
198
200
return True
199
201
200
202
if not raise_ex :
@@ -217,7 +219,8 @@ def validate_ex(expected_schema, # type: Schema
217
219
validate_ex (s , datum , identifiers , strict = strict ,
218
220
foreign_properties = foreign_properties ,
219
221
raise_ex = True ,
220
- strict_foreign_properties = strict_foreign_properties )
222
+ strict_foreign_properties = strict_foreign_properties ,
223
+ logger = logger )
221
224
except ClassValidationException as e :
222
225
raise
223
226
except ValidationException as e :
@@ -269,7 +272,8 @@ def validate_ex(expected_schema, # type: Schema
269
272
if not validate_ex (f .type , fieldval , identifiers , strict = strict ,
270
273
foreign_properties = foreign_properties ,
271
274
raise_ex = raise_ex ,
272
- strict_foreign_properties = strict_foreign_properties ):
275
+ strict_foreign_properties = strict_foreign_properties ,
276
+ logger = logger ):
273
277
return False
274
278
except ValidationException as v :
275
279
if f .name not in datum :
0 commit comments