diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
index 02e727d..e972085 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
@@ -1,6 +1,7 @@
 package org.gcube.accounting.aggregator.persist;
 
 import java.io.File;
+import java.util.concurrent.TimeUnit;
 
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceFactory;
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceSrc;
@@ -37,6 +38,7 @@ public class DeleteDocument extends DocumentElaboration {
 			String id = jsonNode.get(ID).asText();
 			logger.trace("Going to delete record with id {}", id);
 			aggregatorPersistenceSrc.deleteRecord(jsonNode);
+			TimeUnit.MILLISECONDS.sleep(2);
 		}
 	}
 
diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java b/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
index 86e1943..0707782 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/DocumentElaboration.java
@@ -84,7 +84,6 @@ public abstract class DocumentElaboration {
 					}
 					try {
 						elaborateLine(line);
-						TimeUnit.MILLISECONDS.sleep(3);
 						elaborate = false;
 					} catch(Exception e) {
 						if(i != 1) {
diff --git a/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java b/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
index b94e855..3233524 100644
--- a/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
+++ b/src/main/java/org/gcube/accounting/aggregator/persist/InsertDocument.java
@@ -6,6 +6,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.TreeMap;
+import java.util.concurrent.TimeUnit;
 
 import org.gcube.accounting.aggregator.elaboration.Elaborator;
 import org.gcube.accounting.aggregator.persistence.AggregatorPersistenceDst;
@@ -118,6 +119,7 @@ public class InsertDocument extends DocumentElaboration {
 //			count = 0;
 //		}
 		
+		TimeUnit.MILLISECONDS.sleep(2);
 	}
 
 	@Override