class_docstr: A TPU pod command runner.
class_docstr_tok: ["A","TPU","pod","command","runner","."]
docstr: Rsync files down from the cluster node.
  
  Args:
      source: The (remote) source directory or file.
      target: The (local) destination path.
docstr_tok: ["Rsync","files","down","from","the","cluster","node",".","Args",":","source",":","The","(","remote",")","source","directory","or","file",".","target",":","The","(","local",")","destination","path","."]
code: def run_rsync_down(self, *args, **kwargs) -> None:
      """Rsync files down from the cluster node.
  
      Args:
          source: The (remote) source directory or file.
          target: The (local) destination path.
      """
      with ThreadPoolExecutor(self.num_connections) as executor:
          executor.map(
              lambda i: self._command_runners[i].run_rsync_down(
                  *args, **kwargs
              ),
              range(self._num_workers),
          )
  
imports: import copy
  from concurrent.futures import ThreadPoolExecutor
  from types import ModuleType
  from typing import Any, Dict, Optional
  from ray._private import ray_constants
  from ray.autoscaler._private.command_runner import DockerCommandRunner, SSHCommandRunner
  from ray.autoscaler._private.gcp.node import GCPTPUNode
  from ray.autoscaler.command_runner import CommandRunnerInterface
  from ray.autoscaler.node_provider import NodeProvider
label_desc: Use image node_id 5 for calling the TPUCommandRunner obj's underlying member method code with example usage: obj.run_rsync_down() without return types