hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

set event_log_reporter_enabled True by default (#18112)

Browse source
This commit is contained in:
Guyang Song 2021-10-08 14:09:36 +08:00 • committed by GitHub
parent 1aab892623
commit c4bc05bbab
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/ray/common/ray_config_def.h
View file

@ -477,7 +477,7 @@ RAY_CONFIG(int64_t, grpc_keepalive_time_ms, 10000);
RAY_CONFIG(int64_t, grpc_keepalive_timeout_ms, 20000);
/// Whether to use log reporter in event framework
RAY_CONFIG(bool, event_log_reporter_enabled, false)
RAY_CONFIG(bool, event_log_reporter_enabled, true)
/// Whether to use log reporter in event framework
RAY_CONFIG(bool, actor_register_async, true)

5
src/ray/core_worker/core_worker.cc
View file

@ -762,6 +762,11 @@ CoreWorker::CoreWorker(const CoreWorkerOptions &options, const WorkerID &worker_
},
event_stats_print_interval_ms);
}
// Set event context for current core worker thread.
RayEventContext::Instance().SetEventContext(
ray::rpc::Event_SourceType::Event_SourceType_CORE_WORKER,
{{"worker_id", worker_id.Hex()}});
}
void CoreWorker::Shutdown() {