hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-09 04:46:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix (#17660)

Browse source
This commit is contained in:
SangBin Cho 2021-08-07 18:07:27 -07:00 • committed by Kai Fricke
parent 6b4f70add5
commit 658e3668ae
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/ray/pubsub/publisher.cc
View file

@ -95,7 +95,9 @@ bool SubscriptionIndex<KeyIdType>::EraseEntry(const std::string &key_id_binary,
auto object_it = objects.find(key_id);
if (object_it == objects.end()) {
auto it = key_id_to_subscribers_.find(key_id);
if (it != key_id_to_subscribers_.end()) {
RAY_CHECK(it->second.count(subscriber_id) == 0);
}
return false;
}
objects.erase(object_it);