wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-08 21:34:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Set progress report interval for bazel explicitly (#6262)

Browse Source 
* set progress internval

* add keep alive

* add keepalive

* remove cat

* smaller time

* squash error

* reduce log spam
This commit is contained in:
Eric Liang
2019-11-24 22:37:59 -08:00
committed by GitHub
parent c8b69727cd
commit 7917bbef78
3 changed files with 34 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/core_worker/core_worker.cc
+3 -2
View File
@@ -264,8 +264,9 @@ void CoreWorker::ReportActiveObjectIDs() {
std::unordered_set<ObjectID> active_object_ids =
reference_counter_->GetAllInScopeObjectIDs();
RAY_LOG(DEBUG) << "Sending " << active_object_ids.size() << " object IDs to raylet.";
if (active_object_ids.size() > RayConfig::instance().raylet_max_active_object_ids()) {
RAY_LOG(WARNING) << active_object_ids.size() << " object IDs are currently in scope.";
auto max_active = RayConfig::instance().raylet_max_active_object_ids();
if (max_active && active_object_ids.size() > max_active) {
RAY_LOG(INFO) << active_object_ids.size() << " object IDs are currently in scope.";
}
if (!raylet_client_->ReportActiveObjectIDs(active_object_ids).ok()) {