diff --git a/datapackage_pipelines/lib/set_types.py b/datapackage_pipelines/lib/set_types.py index 9cde66ae..a3c08e15 100644 --- a/datapackage_pipelines/lib/set_types.py +++ b/datapackage_pipelines/lib/set_types.py @@ -6,10 +6,11 @@ def flow(parameters): resources = parameters.get('resources') regex = parameters.get('regex', True) + preserve_missing_values = parameters.get('preserve_missing_values', False) if 'types' in parameters: return Flow( *[ - set_type(name, resources=resources, regex=regex, **options) + set_type(name, resources=resources, preserve_missing_values=preserve_missing_values, regex=regex, **options) if options is not None else delete_fields([name], resources=resources) for name, options in parameters['types'].items()