diff --git a/service/migration_manager.cc b/service/migration_manager.cc index 89f29b07b4..d0efcd1407 100644 --- a/service/migration_manager.cc +++ b/service/migration_manager.cc @@ -56,7 +56,9 @@ migration_manager::migration_manager(migration_notifier& notifier, gms::feature_ , _group0_barrier(this_shard_id() == 0 ? std::function()>([this] () -> future<> { // This will run raft barrier and will sync schema with the leader - (void)co_await start_group0_operation(); + return with_scheduling_group(_storage_proxy.get_db().local().get_gossip_scheduling_group(), [this] { + return start_group0_operation().discard_result(); + }); }) : std::function()>([this] () -> future<> { co_await container().invoke_on(0, [] (migration_manager& mm) -> future<> {