qpipe.py 文件源码

def results(self):
        """Start the flow, block until completion, and return the results.
        """
        if self._started_operating:
            raise Exception("You cannot start a pipe flow that has already been run")
        result_pipe = self._result_pipe()

        if is_backend(Backend.MULTIPROCESSING):
            result_pipe._results = multiprocessing.Manager().list()
        else:
            result_pipe._results = []

        self.execute()

        if is_backend(Backend.MULTIPROCESSING):
            return list(result_pipe._results)
        else:
            return result_pipe._results