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

lint

Browse source
This commit is contained in:
Dmitri Gekhtman 2021-05-24 14:00:39 -07:00
parent 02e007fbc5
commit 32040b2f91
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/ray/raylet/node_manager.cc
View file

@ -17,6 +17,7 @@
#include <cctype>
#include <fstream>
#include <memory>
#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),