hunk.code_window:         "1.2.3.4",
           pattern=f"-avz {local_mount} ray@1.2.3.4:{remote_host_mount}")
       process_runner.clear_history()
       ##############################
       process_runner.respond_to_call("docker inspect -f", "true")
       cmd_runner.run_rsync_up(
           local_file, remote_file, options={"file_mount": False})
  
hunk.labels: keep keep keep keep keep replace keep keep keep
hunk.after_edit:     process_runner.respond_to_call("docker inspect -f", ["true"])
  
hunk.file_path: python/ray/tests/test_command_runner.py
hunk.type: replace
file: #pragma once
  
  #include <boost/asio/thread_pool.hpp>
  #include <memory>
  #include <queue>
  
  #include "../native_ray_runtime.h"
  #include "invocation_spec.h"
  #include "ray/core.h"
  #include "task_submitter.h"
  
  namespace ray {
  namespace api {
  
  class NativeTaskSubmitter : public TaskSubmitter {
   public:
    NativeTaskSubmitter(NativeRayRuntime &native_ray_tuntime);
  
    ObjectID SubmitTask(const InvocationSpec &invocation);
  
    ActorID CreateActor(RemoteFunctionPtrHolder &fptr,
                        std::shared_ptr<msgpack::sbuffer> args);
  
    ObjectID SubmitActorTask(const InvocationSpec &invocation);
  
   private:
    NativeRayRuntime &native_ray_tuntime_;
  
    ObjectID Submit(const InvocationSpec &invocation, TaskType type);
  };
  }  // namespace api
  }  // namespace ray