diff --git a/src/ray/core_worker/core_worker.cc b/src/ray/core_worker/core_worker.cc index f5592a88b..75ad4902e 100644 --- a/src/ray/core_worker/core_worker.cc +++ b/src/ray/core_worker/core_worker.cc @@ -28,20 +28,11 @@ CoreWorker::CoreWorker( RayLog::InstallFailureSignalHandler(); } - boost::asio::signal_set sigint(io_service_, SIGINT); - sigint.async_wait( + boost::asio::signal_set signals(io_service_, SIGINT, SIGTERM); + signals.async_wait( [](const boost::system::error_code &error, int signal_number) -> void { if (!error) { - RAY_LOG(WARNING) << "Got SIGINT " << signal_number << ", ignoring it."; - } - }); - - boost::asio::signal_set sigterm(io_service_, SIGTERM); - sigterm.async_wait( - [this](const boost::system::error_code &error, int signal_number) -> void { - if (!error) { - RAY_LOG(WARNING) << "Got SIGTERM " << signal_number << ", shutting down."; - io_service_.stop(); + exit(signal_number); } });