diff --git a/common/src/async-queue.ts b/common/src/async-queue.ts
index f9baa5108..9a3d52969 100644
--- a/common/src/async-queue.ts
+++ b/common/src/async-queue.ts
@@ -160,7 +160,7 @@ export function createAsyncQueueFromGenerator<T>(generator: AsyncGenerator<T>) {
     (async() => {
         try {
             for await (const i of generator) {
-                q.submit(i);
+                await q.enqueue(i);
             }
         }
         catch (e) {