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

[XRay] Fix linting (#1809)

Browse Source
This commit is contained in:
Philipp Moritz
2018-04-01 23:11:06 -07:00
committed by Robert Nishihara
parent 6e06a9e338
commit 0bda11e009
2 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/raylet/lineage_cache.cc
+3 -3
View File
@@ -248,9 +248,9 @@ Status LineageCache::Flush() {
}
// Write back all ready tasks whose arguments have been committed to the GCS.
gcs::raylet::TaskTable::WriteCallback task_callback =
[this](ray::gcs::AsyncGcsClient *client, const TaskID &id,
const std::shared_ptr<protocol::TaskT> data) { HandleEntryCommitted(id); };
gcs::raylet::TaskTable::WriteCallback task_callback = [this](
ray::gcs::AsyncGcsClient *client, const TaskID &id,
const std::shared_ptr<protocol::TaskT> data) { HandleEntryCommitted(id); };
for (const auto &ready_task_id : ready_task_ids) {
auto task = lineage_.GetEntry(ready_task_id);
// TODO(swang): Make this better...
src/ray/raylet/worker_pool_test.cc
+2 -4
View File
@@ -13,10 +13,8 @@ class WorkerPoolTest : public ::testing::Test {
WorkerPoolTest() : worker_pool_(0, {}), io_service_() {}
std::shared_ptr<Worker> CreateWorker(pid_t pid) {
std::function<void(std::shared_ptr<LocalClientConnection>)> client_handler =
[this](std::shared_ptr<LocalClientConnection> client) {
HandleNewClient(client);
};
std::function<void(std::shared_ptr<LocalClientConnection>)> client_handler = [this](
std::shared_ptr<LocalClientConnection> client) { HandleNewClient(client); };
std::function<void(std::shared_ptr<LocalClientConnection>, int64_t, const uint8_t *)>
message_handler = [this](std::shared_ptr<LocalClientConnection> client,
int64_t message_type, const uint8_t *message) {