diff --git a/python/ray/tune/log_sync.py b/python/ray/tune/log_sync.py index 2e18a8658..109c11a01 100644 --- a/python/ray/tune/log_sync.py +++ b/python/ray/tune/log_sync.py @@ -107,11 +107,13 @@ class _LogSyncer(object): if not distutils.spawn.find_executable("rsync"): logger.error("Log sync requires rsync to be installed.") return + source = '{}@{}:{}/'.format(ssh_user, self.worker_ip, + self.local_dir) + target = '{}/'.format(self.local_dir) worker_to_local_sync_cmd = (( - """rsync -avz -e "ssh -i {} -o ConnectTimeout=120s """ - """-o StrictHostKeyChecking=no" '{}@{}:{}/' '{}/'""").format( - quote(ssh_key), ssh_user, self.worker_ip, - quote(self.local_dir), quote(self.local_dir))) + """rsync -savz -e "ssh -i {} -o ConnectTimeout=120s """ + """-o StrictHostKeyChecking=no" {} {}""").format( + quote(ssh_key), quote(source), quote(target))) if self.remote_dir: if self.remote_dir.startswith(S3_PREFIX):