def resolve_processor(self, processor_name):

        if processor_name in helpers.builtin_processors():
            processor_class = helpers.builtin_processors()[processor_name]
        else:
            # resolve a custom processor
            _module, _class = processor_name.rsplit('.', 1)
            try:
                processor_class = getattr(importlib.import_module(_module),
                                          _class)
            except ImportError as e:
                # TODO: something better here
                raise e

        return processor_class
Return a processor class.
dataset/ETHPy150Open frictionlessdata/goodtables/goodtables/pipeline/pipeline.py/Pipeline.resolve_processor