We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 05e2748 commit b08765aCopy full SHA for b08765a
src/ray/raylet/worker_pool.cc
@@ -164,7 +164,10 @@ void WorkerPool::RegisterWorker(const std::shared_ptr<Worker> &worker) {
164
state.registered_workers.insert(std::move(worker));
165
166
auto it = state.starting_worker_processes.find(pid);
167
- RAY_CHECK(it != state.starting_worker_processes.end());
+ if (it == state.starting_worker_processes.end()) {
168
+ RAY_LOG(WARNING) << "Received a register request from an unknown worker " << pid;
169
+ return;
170
+ }
171
it->second--;
172
if (it->second == 0) {
173
state.starting_worker_processes.erase(it);
0 commit comments