diff --git a/runner/src/stream-handler/worker.ts b/runner/src/stream-handler/worker.ts
index 5897c0880..030b8e770 100644
--- a/runner/src/stream-handler/worker.ts
+++ b/runner/src/stream-handler/worker.ts
@@ -53,7 +53,7 @@ function incrementId (id: string): string {
 }
 
 async function blockQueueProducer (workerContext: WorkerContext, streamKey: string): Promise<void> {
-  const HISTORICAL_BATCH_SIZE = 100;
+  const HISTORICAL_BATCH_SIZE = 10;
   let streamMessageStartId = '0';
 
   while (true) {