diff --git a/src/ray/gcs/client_test.cc b/src/ray/gcs/client_test.cc index 6cc0eec2c..fd913fa00 100644 --- a/src/ray/gcs/client_test.cc +++ b/src/ray/gcs/client_test.cc @@ -236,9 +236,8 @@ void TestLogAppendAt(const JobID &job_id, std::shared_ptr c RAY_CHECK_OK(client->task_reconstruction_log().AppendAt(job_id, task_id, data_log[1], nullptr, failure_callback, 1)); - auto lookup_callback = [task_id, managers]( - gcs::AsyncGcsClient *client, const UniqueID &id, - const std::vector &data) { + auto lookup_callback = [managers](gcs::AsyncGcsClient *client, const UniqueID &id, + const std::vector &data) { std::vector appended_managers; for (const auto &entry : data) { appended_managers.push_back(entry.node_manager_id); diff --git a/src/ray/gcs/tables.cc b/src/ray/gcs/tables.cc index fa288c935..53dbc2b2c 100644 --- a/src/ray/gcs/tables.cc +++ b/src/ray/gcs/tables.cc @@ -90,7 +90,7 @@ Status Log::Subscribe(const JobID &job_id, const ClientID &client_id, auto d = std::shared_ptr( new CallbackData({client_id, nullptr, subscribe, done, this, client_})); int64_t callback_index = - RedisCallbackManager::instance().add([this, d](const std::string &data) { + RedisCallbackManager::instance().add([d](const std::string &data) { if (data.empty()) { // No notification data is provided. This is the callback for the // initial subscription request. diff --git a/src/ray/object_manager/object_directory.cc b/src/ray/object_manager/object_directory.cc index b4e131bbd..43e7710f1 100644 --- a/src/ray/object_manager/object_directory.cc +++ b/src/ray/object_manager/object_directory.cc @@ -60,9 +60,8 @@ ray::Status ObjectDirectory::ExecuteGetLocations(const ObjectID &object_id) { // Note: Lookup must be synchronous for thread-safe access. // For now, this is only accessed by the main thread. ray::Status status = gcs_client_->object_table().Lookup( - job_id, object_id, - [this, object_id](gcs::AsyncGcsClient *client, const ObjectID &object_id, - const std::vector &data) { + job_id, object_id, [this](gcs::AsyncGcsClient *client, const ObjectID &object_id, + const std::vector &data) { GetLocationsComplete(object_id, data); }); return status; diff --git a/src/ray/object_manager/object_manager.cc b/src/ray/object_manager/object_manager.cc index a815efd5e..60672f788 100644 --- a/src/ray/object_manager/object_manager.cc +++ b/src/ray/object_manager/object_manager.cc @@ -207,7 +207,7 @@ ray::Status ObjectManager::Push(const ObjectID &object_id, const ClientID &clien transfer_queue_.QueueSend(client_id, object_id, info); RAY_CHECK_OK(DequeueTransfers()); }, - [this](const Status &status) { + [](const Status &status) { // Push is best effort, so do nothing here. }); RAY_CHECK_OK(status); diff --git a/src/ray/raylet/node_manager.cc b/src/ray/raylet/node_manager.cc index 54601a7b1..5ed6bc150 100644 --- a/src/ray/raylet/node_manager.cc +++ b/src/ray/raylet/node_manager.cc @@ -92,7 +92,7 @@ void NodeManager::ClientAdded(gcs::AsyncGcsClient *client, const UniqueID &id, }; ray::Status status = client->heartbeat_table().Subscribe( UniqueID::nil(), UniqueID::nil(), heartbeat_added, - [this](gcs::AsyncGcsClient *client) { + [](gcs::AsyncGcsClient *client) { RAY_LOG(DEBUG) << "heartbeat table subscription done callback called."; }); RAY_CHECK_OK(status);