environment/lib/python2.7/site-packages/IPython/parallel/client/asyncresult.py
def _wait_for_outputs(self, timeout=-1):
        """wait for the 'status=idle' message that indicates we have all outputs
        """
        if not self._success:
            # don't wait on errors
            return
        tic = time.time()
        while not all(md['outputs_ready'] for md in self._metadata):
            time.sleep(0.01)
            self._client._flush_iopub(self._client._iopub_socket)
            if timeout >= 0 and time.time() > tic + timeout:
                break
def _wait_for_outputs(self, timeout=-1):
        if not self._success:
            # don't wait on errors
            return
        tic = time.time()
        while not all(md['outputs_ready'] for md in self._metadata):
            time.sleep(0.01)
            self._client._flush_iopub(self._client._iopub_socket)
            if timeout >= 0 and time.time() > tic + timeout:
                break
def _wait_for_outputs ( self , timeout = - 1 ) : if not self . _success : # don't wait on errors return tic = time . time ( ) while not all ( md [ 'outputs_ready' ] for md in self . _metadata ) : time . sleep ( 0.01 ) self . _client . _flush_iopub ( self . _client . _iopub_socket ) if timeout >= 0 and time . time ( ) > tic + timeout : break
wait for the 'status=idle' message that indicates we have all outputs
wait for the status = idle message that indicates we have all outputs