Created a v3-catalog test script for queues

Author: matt-aitken

references/v3-catalog/package.json

@@ -4,7 +4,8 @@
   "private": true,
   "scripts": {
     "dev:trigger": "triggerdev dev",
-    "management": "ts-node -r tsconfig-paths/register ./src/management.ts"
+    "management": "ts-node -r tsconfig-paths/register ./src/management.ts",
+    "queues": "ts-node -r tsconfig-paths/register ./src/queues.ts"
   },
   "dependencies": {
     "@ffmpeg-installer/ffmpeg": "^1.1.0",
@@ -54,4 +55,4 @@
     "tsconfig-paths": "^4.2.0",
     "typescript": "^5.3.0"
   }
-}
+}

references/v3-catalog/src/queues.ts

@@ -0,0 +1,32 @@
+import dotenv from "dotenv";
+import { simpleChildTask } from "./trigger/subtasks";
+
+dotenv.config();
+
+export async function run() {
+  await simpleChildTask.trigger({ message: "Regular queue" });
+  await simpleChildTask.trigger(
+    { message: "Alt queue" },
+    {
+      queue: {
+        name: "queue-concurrency-3",
+        concurrencyLimit: 3,
+      },
+    }
+  );
+
+  await simpleChildTask.batchTrigger([{ payload: { message: "Regular queue" } }]);
+  await simpleChildTask.batchTrigger([
+    {
+      payload: { message: "Regular queue" },
+      options: {
+        queue: {
+          name: "queue-concurrency-3",
+          concurrencyLimit: 3,
+        },
+      },
+    },
+  ]);
+}
+
+run().catch(console.error);