Merge pull request #4621 from activepieces/fix/queue

fix: queue fix
activepieces · May 3, 2024 · 4ff6dbb · 4ff6dbb
2 parents 2aa3900 + 95267a4
commit 4ff6dbb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/packages/pieces/community/queue/package.json b/packages/pieces/community/queue/package.json
@@ -1,4 +1,4 @@
 {
   "name": "@activepieces/piece-queue",
-  "version": "0.0.1"
+  "version": "0.0.2"
 }
diff --git a/packages/pieces/community/queue/src/lib/actions/push-to-queue.ts b/packages/pieces/community/queue/src/lib/actions/push-to-queue.ts
@@ -28,16 +28,16 @@ export const pushToQueue = createAction({
     }),
   },
   async run(context) {
-    await push({ store: context.store, queueName: context.propsValue.queueName, items: context.propsValue.items, testing: false })
+    return push({ store: context.store, queueName: context.propsValue.queueName, items: context.propsValue.items, testing: false })
   },
   async test(context) {
-    await push({ store: context.store, queueName: context.propsValue.queueName, items: context.propsValue.items, testing: true })
+    return push({ store: context.store, queueName: context.propsValue.queueName, items: context.propsValue.items, testing: true })
   }
 });
 
 async function push({ store, queueName, items, testing }: { store: Store, queueName: string, items: unknown[], testing: boolean }) {
   const key = constructQueueName(queueName, testing)
-  const existingQueueItems = await store.get(queueName, StoreScope.PROJECT) || []
-  const updatedQueueItems = [...existingQueueItems as unknown[], ...items]
+  const existingQueueItems = await store.get<unknown[]>(key, StoreScope.PROJECT) || []
+  const updatedQueueItems = [...existingQueueItems, ...items]
   await store.put(key, updatedQueueItems, StoreScope.PROJECT)
 }