[skip ci] reproduce (failing) test for cluster-delete
@@ -289,6 +289,19 @@ func testDistributed(t *testing.T, dirName string, batch bool) {
assert.Equal(t, expectedResult, res)
})
+
+ t.Run("delete a third of the data from random nodes", func(t *testing.T) {
+ for i, obj := range data {
+ if i%3 != 0 {
+ // keep this item
+ continue
+ }
+
+ node := nodes[rand.Intn(len(nodes))]
+ err := node.repo.DeleteObject(context.Background(), "Distributed", obj.ID)
+ require.Nil(t, err)
+ }
+ })
}
func setupDirectory() (string, func()) {
