@@ -176,7 +176,8 @@ def validate_ex(expected_schema, # type: Schema
176176 strict = strict ,
177177 foreign_properties = foreign_properties ,
178178 raise_ex = raise_ex ,
179- strict_foreign_properties = strict_foreign_properties ):
179+ strict_foreign_properties = strict_foreign_properties ,
180+ logger = logger ):
180181 return False
181182 except ValidationException as v :
182183 if raise_ex :
@@ -194,7 +195,8 @@ def validate_ex(expected_schema, # type: Schema
194195 elif isinstance (expected_schema , avro .schema .UnionSchema ):
195196 for s in expected_schema .schemas :
196197 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 ):
198200 return True
199201
200202 if not raise_ex :
@@ -217,7 +219,8 @@ def validate_ex(expected_schema, # type: Schema
217219 validate_ex (s , datum , identifiers , strict = strict ,
218220 foreign_properties = foreign_properties ,
219221 raise_ex = True ,
220- strict_foreign_properties = strict_foreign_properties )
222+ strict_foreign_properties = strict_foreign_properties ,
223+ logger = logger )
221224 except ClassValidationException as e :
222225 raise
223226 except ValidationException as e :
@@ -269,7 +272,8 @@ def validate_ex(expected_schema, # type: Schema
269272 if not validate_ex (f .type , fieldval , identifiers , strict = strict ,
270273 foreign_properties = foreign_properties ,
271274 raise_ex = raise_ex ,
272- strict_foreign_properties = strict_foreign_properties ):
275+ strict_foreign_properties = strict_foreign_properties ,
276+ logger = logger ):
273277 return False
274278 except ValidationException as v :
275279 if f .name not in datum :
0 commit comments