Velimir Mlaker comments

Results 6 comments of


                                            Velimir Mlaker

does mpipe support the unidirectional graph pipeline/topology?

Fan-in is not supported, and will have undefined results. ``` python stage1.link(stage2.link(stage3)) stage1.link(stage3) # This is bad. ``` A problem can arise with propagating the `None` task to signal STOP...

Odd Hanging Behaviour on OrderedWorkers Based On Payload Size

@lycovian, unfortunately i'm not able to duplicate the result--it's not hanging on my platform with either 95 or 96 character string (Python 2.7.12 and 3.5.2, mpipe version 1.0.8, Ubuntu 16.04.)...

Basic Example broken.

Sorry, hasn't been tested on Windows. Are you running this from the Python console? Try saving the code to a file and run with command: `python test.py`

Pipeline.results() returns partial results when there are multiple end stages

Hi, if you have a pipeline implementation that illustrates the problem you're seeing, I will gladly take a look. If this is related to #8, then fan-in is the culprit.

Please explain if/how one can avoid putting too much data into a pipeline

You're right: when you `put` data on the pipeline, it's either put on a `multiprocessing.Queue` in case of an UnorderedStage, or sent to a `multiprocessing.Pipe` if using an OrderedStage. Both...

Please explain if/how one can avoid putting too much data into a pipeline

The `maxsize` parameter is not implemented. This is a good idea; I'm noting this a **requested enhancement**. Also, there is no facility to retrieve total count/size of tasks submitted and...