def __init__(self, registry):
        '''Create a pipeline factory.

        :param dict config: top-level "streamcorpus_pipeline" configuration
        :param registry: registry of stages
        :type registry: :class:`~streamcorpus_pipeline.stages.StageRegistry`

        '''
        super(PipelineFactory, self).__init__()
        self.registry = registry
        self.lock = threading.Lock()
        self.tmp_dir_suffix = None
def __init__ ( self , registry ) : super ( PipelineFactory , self ) . __init__ ( ) self . registry = registry self . lock = threading . Lock ( ) self . tmp_dir_suffix = None
Create a pipeline factory.

        :param dict config: top-level "streamcorpus_pipeline" configuration
        :param registry: registry of stages
        :type registry: :class:`~streamcorpus_pipeline.stages.StageRegistry`