def create_processing_function(settings, pipeline):
    processors = []
    for processor in pipeline:
        processor_class = import_class(processor)
        processors.append(processor_class(settings))

    def processing(data_message):
        """
        The actual processing function calling each configured processor in the
        order they have been configured.
        """
        next_message = data_message
        for processor in processors:
            next_message = processor(next_message)
        return next_message

    return processing
Creates a search using a search query and any additional parameters
dataset/ETHPy150Open retresco/Spyder/src/spyder/workerprocess.py/create_processing_function--crossover with--dataset/ETHPy150Open hvandenb/splunk-elasticsearch/search-elasticsearch/bin/splunklib/client.py/Jobs.create