def cumprod(self, axis, dtype=None):
        from .reductions import cumprod
        return cumprod(self, axis, dtype)
Drain the subprocesses output streams, writing the collected output
dataset/ETHPy150Open dask/dask/dask/array/core.py/Array.cumprod--crossover with--dataset/ETHPy150Open buanzo/jiffy/gnupg.py/GPG._collect_output