4047
4047
# missing keys can handle suspending a write group).
4048
4048
write_group_tokens = self.target_repo.suspend_write_group()
4049
4049
return write_group_tokens, missing_keys
4053
4056
def _extract_and_insert_inventories(self, substream, serializer):