in granule_ingester/granule_ingester/pipeline/Pipeline.py [0:0]
def _parse_module(cls, module_config: dict, module_mappings: dict):
module_name = module_config.pop('name')
try:
module_class = module_mappings[module_name]
logger.debug("Loaded processor {}.".format(module_class))
processor_module = module_class(**module_config)
except KeyError:
raise PipelineBuildingError(f"'{module_name}' is not a valid processor.")
except Exception as e:
raise PipelineBuildingError(f"Parsing module '{module_name}' failed because of the following error: {e}")
return processor_module