@@ -14,45 +14,19 @@ export const deadlockReleasingQueue = queue({
14
14
export const deadlockTester = task ( {
15
15
id : "deadlock-tester" ,
16
16
run : async ( payload : any , { ctx } ) => {
17
- // await deadlockNestedTask.triggerAndWait({
18
- // message: "Hello, world!",
19
- // });
20
-
21
- await deadlockNestedTask . batchTriggerAndWait ( [
22
- {
23
- payload : {
24
- message : "Hello, world!" ,
25
- } ,
26
- } ,
27
- {
28
- payload : {
29
- message : "Hello, world!" ,
30
- } ,
31
- } ,
32
- ] ) ;
17
+ await deadlockNestedTask . triggerAndWait ( {
18
+ message : "Hello, world!" ,
19
+ } ) ;
33
20
} ,
34
21
} ) ;
35
22
36
23
export const deadlockNestedTask = task ( {
37
24
id : "deadlock-nested-task" ,
38
25
queue : deadlockQueue ,
39
26
run : async ( payload : any , { ctx } ) => {
40
- // await deadlockTester.triggerAndWait({
41
- // message: "Hello, world!",
42
- // });
43
-
44
- await deadlockTester . batchTriggerAndWait ( [
45
- {
46
- payload : {
47
- message : "Hello, world!" ,
48
- } ,
49
- } ,
50
- {
51
- payload : {
52
- message : "Hello, world!" ,
53
- } ,
54
- } ,
55
- ] ) ;
27
+ await deadlockTester . triggerAndWait ( {
28
+ message : "Hello, world!" ,
29
+ } ) ;
56
30
57
31
return {
58
32
message : "Hello, world!" ,
0 commit comments