From 32040b2f9197f3a3e2cf634b02346b8e00400f61 Mon Sep 17 00:00:00 2001 From: Dmitri Gekhtman Date: Mon, 24 May 2021 14:00:39 -0700 Subject: [PATCH] lint --- src/ray/raylet/node_manager.cc | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc index 5bbf61dbf..900004a5e 100644 --- a/src/ray/raylet/node_manager.cc +++ b/src/ray/raylet/node_manager.cc @@ -17,6 +17,7 @@ #include #include #include + #include "boost/filesystem.hpp" #include "boost/system/error_code.hpp" #include "ray/common/asio/asio_util.h" @@ -209,15 +210,15 @@ NodeManager::NodeManager(instrumented_io_context &io_service, const NodeID &self fair_queueing_enabled_(config.fair_queueing_enabled), temp_dir_(config.temp_dir), initial_config_(config), - worker_pool_(io_service, self_node_id_, config.node_manager_address, - config.num_workers_soft_limit, - config.num_initial_python_workers_for_first_job, - config.maximum_startup_concurrency, config.min_worker_port, - config.max_worker_port, config.worker_ports, gcs_client_, - config.worker_commands, - /*starting_worker_timeout_callback=*/ - [this] { cluster_task_manager_->ScheduleAndDispatchTasks(); }, - /*get_time=*/[]() { return absl::GetCurrentTimeNanos() / 1e6; }), + worker_pool_( + io_service, self_node_id_, config.node_manager_address, + config.num_workers_soft_limit, config.num_initial_python_workers_for_first_job, + config.maximum_startup_concurrency, config.min_worker_port, + config.max_worker_port, config.worker_ports, gcs_client_, + config.worker_commands, + /*starting_worker_timeout_callback=*/ + [this] { cluster_task_manager_->ScheduleAndDispatchTasks(); }, + /*get_time=*/[]() { return absl::GetCurrentTimeNanos() / 1e6; }), dependency_manager_(object_manager_), node_manager_server_("NodeManager", config.node_manager_port), node_manager_service_(io_service, *this),