From 4735c032edf95a406f4040420ad870344e323dd7 Mon Sep 17 00:00:00 2001 From: Kai Yang Date: Thu, 12 Nov 2020 01:04:45 +0800 Subject: [PATCH] [Core] Fix C++ worker test (#11941) --- cpp/src/ray/util/process_helper.cc | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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";