diff --git a/cpp/src/ray/util/process_helper.cc b/cpp/src/ray/util/process_helper.cc index 973e95542..7227337ed 100644 --- a/cpp/src/ray/util/process_helper.cc +++ b/cpp/src/ray/util/process_helper.cc @@ -69,7 +69,9 @@ void ProcessHelper::RayStart(std::shared_ptr config, options.language = Language::CPP; options.store_socket = store_socket; options.raylet_socket = raylet_socket; - options.job_id = JobID::FromInt(1); + if (options.worker_type == WorkerType::DRIVER) { + options.job_id = JobID::FromInt(1); + } options.gcs_options = gcs_options; options.enable_logging = true; options.log_dir = session_dir + "/logs";