Skip to content

Commit c34d025

Browse files
committed
Improved the script in the catalog so it’s clearer what’s going on
1 parent cbb5cbd commit c34d025

File tree

1 file changed

+31
-4
lines changed

1 file changed

+31
-4
lines changed

references/v3-catalog/src/queues.ts

Lines changed: 31 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,23 +6,50 @@ dotenv.config();
66
export async function run() {
77
await simpleChildTask.trigger({ message: "Regular queue" });
88
await simpleChildTask.trigger(
9-
{ message: "Alt queue" },
9+
{ message: "Simple alt queue 1" },
1010
{
1111
queue: {
1212
name: "queue-concurrency-3",
13-
concurrencyLimit: 3,
13+
concurrencyLimit: 1,
14+
},
15+
}
16+
);
17+
await simpleChildTask.trigger(
18+
{ message: "Simple alt queue 2" },
19+
{
20+
queue: {
21+
name: "queue-concurrency-3",
22+
concurrencyLimit: 1,
1423
},
1524
}
1625
);
1726

1827
await simpleChildTask.batchTrigger([{ payload: { message: "Regular queue" } }]);
1928
await simpleChildTask.batchTrigger([
2029
{
21-
payload: { message: "Regular queue" },
30+
payload: { message: "Batched alt queue 1" },
31+
options: {
32+
queue: {
33+
name: "queue-concurrency-3",
34+
concurrencyLimit: 1,
35+
},
36+
},
37+
},
38+
{
39+
payload: { message: "Batched alt queue 2" },
40+
options: {
41+
queue: {
42+
name: "queue-concurrency-3",
43+
concurrencyLimit: 1,
44+
},
45+
},
46+
},
47+
{
48+
payload: { message: "Batched alt queue 3" },
2249
options: {
2350
queue: {
2451
name: "queue-concurrency-3",
25-
concurrencyLimit: 3,
52+
concurrencyLimit: 1,
2653
},
2754
},
2855
},

0 commit comments

Comments
 (0)