diff --git a/db/view/view.cc b/db/view/view.cc index 0a5968347c..3965eacb5a 100644 --- a/db/view/view.cc +++ b/db/view/view.cc @@ -1078,7 +1078,7 @@ future view_update_builder::on_results() { return stop(); } -future make_view_update_builder( +view_update_builder make_view_update_builder( const schema_ptr& base, std::vector&& views_to_update, flat_mutation_reader_v2&& updates, @@ -1092,7 +1092,7 @@ future make_view_update_builder( } return view_updates(std::move(v)); })); - return make_ready_future(view_update_builder(base, std::move(vs), std::move(updates), std::move(existings), now)); + return view_update_builder(base, std::move(vs), std::move(updates), std::move(existings), now); } future calculate_affected_clustering_ranges(const schema& base, diff --git a/db/view/view.hh b/db/view/view.hh index 821335c02d..ec82f02e52 100644 --- a/db/view/view.hh +++ b/db/view/view.hh @@ -203,7 +203,7 @@ private: future stop() const; }; -future make_view_update_builder( +view_update_builder make_view_update_builder( const schema_ptr& base, std::vector&& views_to_update, flat_mutation_reader_v2&& updates, diff --git a/replica/table.cc b/replica/table.cc index b567595792..63b66a4807 100644 --- a/replica/table.cc +++ b/replica/table.cc @@ -1674,7 +1674,7 @@ future<> table::generate_and_propagate_view_updates(const schema_ptr& base, tracing::trace_state_ptr tr_state, gc_clock::time_point now) const { auto base_token = m.token(); - db::view::view_update_builder builder = co_await db::view::make_view_update_builder( + db::view::view_update_builder builder = db::view::make_view_update_builder( base, std::move(views), make_flat_mutation_reader_from_mutations_v2(m.schema(), std::move(permit), std::move(m)), @@ -1809,7 +1809,7 @@ future<> table::populate_views( flat_mutation_reader_v2&& reader, gc_clock::time_point now) { auto schema = reader.schema(); - db::view::view_update_builder builder = co_await db::view::make_view_update_builder( + db::view::view_update_builder builder = db::view::make_view_update_builder( schema, std::move(views), std::move(reader),