Source code for florin.pipelines.workqueue

from florin.pipelines.pipeline import Pipeline


[docs]class WorkQueuePipeline(Pipeline):

[docs]    def run(self, data):
        return next(map(self.operations, data))