environment/lib/python2.7/site-packages/IPython/parallel/apps/launcher.py
def _fetch_file(self, remote, local):
        """fetch a single file"""
        full_remote = "%s:%s" % (self.location, remote)
        self.log.info("fetching %s from %s", local, full_remote)
        for i in range(10):
            # wait up to 10s for remote file to exist
            check = check_output(self.ssh_cmd + self.ssh_args + \
                [self.location, 'test -e', remote, "&& echo 'yes' || echo 'no'"])
            check = check.strip()
            if check == 'no':
                time.sleep(1)
            elif check == 'yes':
                break
        check_output(self.scp_cmd + [full_remote, local])
def _fetch_file(self, remote, local):
        full_remote = "%s:%s" % (self.location, remote)
        self.log.info("fetching %s from %s", local, full_remote)
        for i in range(10):
            # wait up to 10s for remote file to exist
            check = check_output(self.ssh_cmd + self.ssh_args + \
                [self.location, 'test -e', remote, "&& echo 'yes' || echo 'no'"])
            check = check.strip()
            if check == 'no':
                time.sleep(1)
            elif check == 'yes':
                break
        check_output(self.scp_cmd + [full_remote, local])
def _fetch_file ( self , remote , local ) : full_remote = "%s:%s" % ( self . location , remote ) self . log . info ( "fetching %s from %s" , local , full_remote ) for i in range ( 10 ) : # wait up to 10s for remote file to exist check = check_output ( self . ssh_cmd + self . ssh_args + [ self . location , 'test -e' , remote , "&& echo 'yes' || echo 'no'" ] ) check = check . strip ( ) if check == 'no' : time . sleep ( 1 ) elif check == 'yes' : break check_output ( self . scp_cmd + [ full_remote , local ] )
fetch a single file
fetch a single file