jumpoutofworld

Pipeline.get return only one result from its output_stages . I can not catch the design, or a bug ? def get(self, timeout=None): """Return result from the pipeline.""" result = None...

I've tried a pipeline like this: stage1 --> stage2 --> stage3 stage1 --> stage3 That is, stage3 receives tasks from both stage1 and stage2. I've get some wired results. does...