diff --git a/src/ray/core_worker/core_worker.h b/src/ray/core_worker/core_worker.h index af2e14cdc..78e786930 100644 --- a/src/ray/core_worker/core_worker.h +++ b/src/ray/core_worker/core_worker.h @@ -51,6 +51,8 @@ namespace ray { class CoreWorker; +// If you change this options's definition, you must change the options used in +// other files. Please take a global search and modify them !!! struct CoreWorkerOptions { // Callback that must be implemented and provided by the language-specific worker // frontend to execute tasks and return their results. diff --git a/streaming/src/test/mock_actor.cc b/streaming/src/test/mock_actor.cc index f505496f2..0c15d72c6 100644 --- a/streaming/src/test/mock_actor.cc +++ b/streaming/src/test/mock_actor.cc @@ -479,6 +479,7 @@ class StreamingWorker { StreamingWorker(const std::string &store_socket, const std::string &raylet_socket, int node_manager_port, const gcs::GcsClientOptions &gcs_options) : test_suite_(nullptr), peer_actor_handle_(nullptr) { + // You must keep it same with `src/ray/core_worker/core_worker.h:CoreWorkerOptions` CoreWorkerOptions options = { WorkerType::WORKER, // worker_type Language::PYTHON, // langauge @@ -499,6 +500,8 @@ class StreamingWorker { _7), // task_execution_callback nullptr, // check_signals nullptr, // gc_collect + nullptr, // spill_objects + nullptr, // restore_spilled_objects nullptr, // get_lang_stack nullptr, // kill_main true, // ref_counting_enabled diff --git a/streaming/src/test/queue_tests_base.h b/streaming/src/test/queue_tests_base.h index afa1fb7af..f57c31e10 100644 --- a/streaming/src/test/queue_tests_base.h +++ b/streaming/src/test/queue_tests_base.h @@ -223,6 +223,7 @@ class StreamingQueueTestBase : public ::testing::TestWithParam { } STREAMING_LOG(INFO) << "Sub process: writer."; + // You must keep it same with `src/ray/core_worker/core_worker.h:CoreWorkerOptions` CoreWorkerOptions options = { WorkerType::DRIVER, // worker_type Language::PYTHON, // langauge @@ -242,6 +243,8 @@ class StreamingQueueTestBase : public ::testing::TestWithParam { nullptr, // task_execution_callback nullptr, // check_signals nullptr, // gc_collect + nullptr, // spill_objects + nullptr, // restore_spilled_objects nullptr, // get_lang_stack nullptr, // kill_main true, // ref_counting_enabled