diff --git a/service/storage_service.cc b/service/storage_service.cc
index b949f4b9f0..edb66d14dc 100644
--- a/service/storage_service.cc
+++ b/service/storage_service.cc
@@ -650,12 +650,12 @@ void storage_service::on_join(gms::inet_address endpoint, gms::endpoint_state ep
     for (auto e : ep_state.get_application_state_map()) {
         on_change(endpoint, e.first, e.second);
     }
-    get_local_migration_manager().schedule_schema_pull(endpoint, ep_state);
+    get_local_migration_manager().schedule_schema_pull(endpoint, ep_state).get();
 }
 
 void storage_service::on_alive(gms::inet_address endpoint, gms::endpoint_state state) {
     logger.debug("on_alive endpoint={}", endpoint);
-    get_local_migration_manager().schedule_schema_pull(endpoint, state);
+    get_local_migration_manager().schedule_schema_pull(endpoint, state).get();
     if (_token_metadata.is_member(endpoint)) {
 #if 0
         HintedHandOffManager.instance.scheduleHintDelivery(endpoint, true);
@@ -702,7 +702,7 @@ void storage_service::on_change(inet_address endpoint, application_state state,
         }
         do_update_system_peers_table(endpoint, state, value);
         if (state == application_state::SCHEMA) {
-            get_local_migration_manager().schedule_schema_pull(endpoint, *ep_state);
+            get_local_migration_manager().schedule_schema_pull(endpoint, *ep_state).get();
         }
     }
     replicate_to_all_cores().get();