diff --git a/db/system_distributed_keyspace.cc b/db/system_distributed_keyspace.cc index c6442272d0..359fc39234 100644 --- a/db/system_distributed_keyspace.cc +++ b/db/system_distributed_keyspace.cc @@ -353,22 +353,22 @@ future> system_distributed_keyspace::vi future<> system_distributed_keyspace::start_view_build(sstring ks_name, sstring view_name) const { auto host_id = _sp.local_db().get_config().host_id; - return _qp.execute_internal( - format("INSERT INTO {}.{} (keyspace_name, view_name, host_id, status) VALUES (?, ?, ?, ?)", NAME, VIEW_BUILD_STATUS), - db::consistency_level::ONE, - internal_distributed_query_state(), - { std::move(ks_name), std::move(view_name), std::move(host_id), "STARTED" }, - false).discard_result(); + return _qp.execute_internal( + format("INSERT INTO {}.{} (keyspace_name, view_name, host_id, status) VALUES (?, ?, ?, ?)", NAME, VIEW_BUILD_STATUS), + db::consistency_level::ONE, + internal_distributed_query_state(), + { std::move(ks_name), std::move(view_name), std::move(host_id), "STARTED" }, + false).discard_result(); } future<> system_distributed_keyspace::finish_view_build(sstring ks_name, sstring view_name) const { auto host_id = _sp.local_db().get_config().host_id; - return _qp.execute_internal( - format("UPDATE {}.{} SET status = ? WHERE keyspace_name = ? AND view_name = ? AND host_id = ?", NAME, VIEW_BUILD_STATUS), - db::consistency_level::ONE, - internal_distributed_query_state(), - { "SUCCESS", std::move(ks_name), std::move(view_name), std::move(host_id) }, - false).discard_result(); + return _qp.execute_internal( + format("UPDATE {}.{} SET status = ? WHERE keyspace_name = ? AND view_name = ? AND host_id = ?", NAME, VIEW_BUILD_STATUS), + db::consistency_level::ONE, + internal_distributed_query_state(), + { "SUCCESS", std::move(ks_name), std::move(view_name), std::move(host_id) }, + false).discard_result(); } future<> system_distributed_keyspace::remove_view(sstring ks_name, sstring view_name) const {