diff --git a/fdbclient/MultiVersionTransaction.actor.cpp b/fdbclient/MultiVersionTransaction.actor.cpp index 52cb869727..b1eef60004 100644 --- a/fdbclient/MultiVersionTransaction.actor.cpp +++ b/fdbclient/MultiVersionTransaction.actor.cpp @@ -816,10 +816,8 @@ ThreadFuture MultiVersionDatabase::rebootWorker(const StringRef& addres } ThreadFuture MultiVersionDatabase::forceRecoveryWithDataLoss(const StringRef &dcid) { - if (dbState->db) { - return dbState->db->forceRecoveryWithDataLoss(dcid); - } - return Void(); + auto f = dbState->db ? dbState->db->forceRecoveryWithDataLoss(dcid) : ThreadFuture(Never()); + return abortableFuture(f, dbState->dbVar->get().onChange); } void MultiVersionDatabase::Connector::connect() {