File tree Expand file tree Collapse file tree 1 file changed +10
-3
lines changed
Expand file tree Collapse file tree 1 file changed +10
-3
lines changed Original file line number Diff line number Diff line change @@ -344,9 +344,16 @@ CoreWorker &CoreWorkerProcessImpl::GetCoreWorkerForCurrentThread() {
344344 // In this case, we should exit without crashing.
345345 // TODO (scv119): A better solution could be returning error code
346346 // and handling it at language frontend.
347- RAY_LOG (ERROR) << " The global worker has already been shutdown. This happens when "
348- " the language frontend accesses the Ray's worker after it is "
349- " shutdown. The process will exit" ;
347+ if (options_.worker_type == WorkerType::DRIVER) {
348+ RAY_LOG (ERROR)
349+ << " The global worker has already been shutdown. This happens when "
350+ " the language frontend accesses the Ray's worker after it is "
351+ " shutdown. The process will exit" ;
352+ } else {
353+ RAY_LOG (INFO) << " The global worker has already been shutdown. This happens when "
354+ " the language frontend accesses the Ray's worker after it is "
355+ " shutdown. The process will exit" ;
356+ }
350357 QuickExit ();
351358 }
352359 RAY_CHECK (global_worker) << " global_worker_ must not be NULL" ;
You can’t perform that action at this time.
0 commit comments