Don't wrap RayError with RayTaskError (#5870)

python/ray/autoscaler/updater.py

@@ -293,7 +293,7 @@ class SSHCommandRunner(object):
             stdout=redirect,
             stderr=redirect)
 
-    def rsync_down(self, source, target, redirect=None):
+    def run_rsync_down(self, source, target, redirect=None):
         self.set_ssh_ip_if_required()
         self.process_runner.check_call(
             [

python/ray/exceptions.py

@@ -61,6 +61,9 @@ class RayTaskError(RayError):
         if issubclass(RayTaskError, self.cause_cls):
             return self  # already satisfied
 
+        if issubclass(self.cause_cls, RayError):
+            return self  # don't try to wrap ray internal errors
+
         class cls(RayTaskError, self.cause_cls):
             def __init__(self, function_name, traceback_str, cause_cls,
                          proctitle, pid, ip):