The documentation states:
PCollectors can collect from ForkedFeeder‘s or ProcessPool‘s (via system pipes)
...
class PCollector([waittime=0.1]): Collect items from many ForkedFeeder‘s or ProcessPool‘s.
However, when you try to pipe the output of a ProcessPool into a PCollector, it fails:
AttributeError: 'ProcessPool' object has no attribute 'outpipe'
As the error suggests, ForkedFeeder has an attribute 'outpipe', but ProcessPool does not.
I'm not sure how I could be calling it incorrectly, but I'd be glad to hear I was.