diff --git a/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java b/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java
index 1d0289d6..92387927 100644
--- a/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java
+++ b/rxrepo-core/src/main/java/com/slimgears/rxrepo/query/DefaultEntitySet.java
@@ -66,7 +66,12 @@ public Single<Integer> execute() {
                 return queryProvider.delete(builder
                         .metaClass(metaClass)
                         .predicate(predicate.get())
-                        .build());
+                        .build())
+                        .compose(Singles.backOffDelayRetry(
+                                DefaultEntitySet::isConcurrencyException,
+                                Duration.ofMillis(config.retryInitialDurationMillis()),
+                                config.retryCount()));
+
             }
 
             @Override