schema-validator to treat missing fields as None

datahq · Oct 18, 2018 · d598c30 · d598c30
1 parent 4ef7131
commit d598c30
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dataflows/base/schema_validator.py b/dataflows/base/schema_validator.py
@@ -26,7 +26,7 @@ def schema_validator(resource: Resource, iterator, field_names=None):
 
         try:
             for f in schema_fields:
-                row[f.name] = f.cast_value(row[f.name])
+                row[f.name] = f.cast_value(row.get(f.name))
         except CastError as e:
             raise ValidationError(resource.name, row, i, e)