class_docstr: A TPU pod command runner.
class_docstr_tok: ["A","TPU","pod","command","runner","."]
code: def run_rsync_up(self, *args, **kwargs) -> None:
      with ThreadPoolExecutor(self.num_connections) as executor:
          executor.map(
              lambda i: self._command_runners[i].run_rsync_up(
                  *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 4 for calling the TPUCommandRunner obj's underlying member method code with example usage: obj.run_rsync_up() without return types