diff --git a/engine/execution/ingestion/uploader/uploader.go b/engine/execution/ingestion/uploader/uploader.go
index d1dcabb0cbc..d29a0d3a69c 100644
--- a/engine/execution/ingestion/uploader/uploader.go
+++ b/engine/execution/ingestion/uploader/uploader.go
@@ -35,10 +35,10 @@ func NewAsyncUploader(uploader Uploader,
 		maxRetryNumber:      maxRetryNumber,
 		// we use a channel rather than a Fifoqueue here because a Fifoqueue might drop items when full,
 		// but it is not acceptable to skip uploading an execution result
-		queue:               make(chan *execution.ComputationResult, 100),
+		queue:               make(chan *execution.ComputationResult, 20000),
 	}
 	builder := component.NewComponentManagerBuilder()
-	for i := 0; i < 3; i++ {
+	for i := 0; i < 10; i++ {
 		builder.AddWorker(a.UploadWorker)
 	}
 	a.cm = builder.Build()