diff --git a/tensorflow_recommenders_addons/dynamic_embedding/core/kernels/redis_impl/redis_cluster_connection_pool.hpp b/tensorflow_recommenders_addons/dynamic_embedding/core/kernels/redis_impl/redis_cluster_connection_pool.hpp index b0b49787..dea195ce 100644 --- a/tensorflow_recommenders_addons/dynamic_embedding/core/kernels/redis_impl/redis_cluster_connection_pool.hpp +++ b/tensorflow_recommenders_addons/dynamic_embedding/core/kernels/redis_impl/redis_cluster_connection_pool.hpp @@ -1305,12 +1305,14 @@ every bucket has its own BucketContext for sending data---for locating reply- std::vector>> exists_chars(storage_slice); for (unsigned i = 0; i < storage_slice; ++i) { if (!exists_split[i].empty()) { - exists_chars[i] = std::make_unique>(exists_split[i].size()); - std::transform(exists_split[i].begin(), exists_split[i].end(), exists_chars[i]->begin(), [](bool b) { - return static_cast(b); - }); - - thread_context->HandlePushBack(i, exists_chars[i]->data(), exists_chars[i]->size() * sizeof(char)); + exists_chars[i] = + std::make_unique>(exists_split[i].size()); + std::transform(exists_split[i].begin(), exists_split[i].end(), + exists_chars[i]->begin(), + [](bool b) { return static_cast(b); }); + + thread_context->HandlePushBack(i, exists_chars[i]->data(), + exists_chars[i]->size() * sizeof(char)); } }