fix: poppingChangeFeeds did not properly handle broken promise errors

This commit is contained in:
Evan Tschannen 2022-01-10 10:14:54 -08:00
parent 21309fb55b
commit 91574fa0b9
1 changed files with 1 additions and 1 deletions

View File

@ -8039,7 +8039,7 @@ ACTOR Future<Void> popChangeFeedMutationsActor(Reference<DatabaseContext> db, Ke
}
} catch (Error& e) {
if (e.code() != error_code_unknown_change_feed && e.code() != error_code_wrong_shard_server &&
e.code() != error_code_all_alternatives_failed) {
e.code() != error_code_all_alternatives_failed && e.code() != error_code_broken_promise) {
throw;
}
db->changeFeedCache.erase(rangeID);