@@ -367,14 +367,14 @@ function makeUpdateActivationJob(
367
367
id : string ,
368
368
protocolInstanceId : string ,
369
369
name : string ,
370
- input : unknown
370
+ input : unknown [ ]
371
371
) : coresdk . workflow_activation . IWorkflowActivationJob {
372
372
return {
373
373
doUpdate : {
374
374
id,
375
375
protocolInstanceId,
376
376
name,
377
- input : toPayloads ( defaultPayloadConverter , input ) ,
377
+ input : toPayloads ( defaultPayloadConverter , ... input ) ,
378
378
} ,
379
379
} ;
380
380
}
@@ -2543,13 +2543,13 @@ test('Buffered updates are dispatched in the correct order - updatesOrdering', a
2543
2543
makeActivation (
2544
2544
undefined ,
2545
2545
makeInitializeWorkflowJob ( workflowType ) ,
2546
- makeUpdateActivationJob ( '1' , '1' , 'non-existant' , 1 ) ,
2547
- makeUpdateActivationJob ( '2' , '2' , 'updateA' , 2 ) ,
2548
- makeUpdateActivationJob ( '3' , '3' , 'updateA' , 3 ) ,
2549
- makeUpdateActivationJob ( '4' , '4' , 'updateC' , 4 ) ,
2550
- makeUpdateActivationJob ( '5' , '5' , 'updateB' , 5 ) ,
2551
- makeUpdateActivationJob ( '6' , '6' , 'non-existant' , 6 ) ,
2552
- makeUpdateActivationJob ( '7' , '7' , 'updateB' , 7 )
2546
+ makeUpdateActivationJob ( '1' , '1' , 'non-existant' , [ 1 ] ) ,
2547
+ makeUpdateActivationJob ( '2' , '2' , 'updateA' , [ 2 ] ) ,
2548
+ makeUpdateActivationJob ( '3' , '3' , 'updateA' , [ 3 ] ) ,
2549
+ makeUpdateActivationJob ( '4' , '4' , 'updateC' , [ 4 ] ) ,
2550
+ makeUpdateActivationJob ( '5' , '5' , 'updateB' , [ 5 ] ) ,
2551
+ makeUpdateActivationJob ( '6' , '6' , 'non-existant' , [ 6 ] ) ,
2552
+ makeUpdateActivationJob ( '7' , '7' , 'updateB' , [ 7 ] )
2553
2553
)
2554
2554
) ;
2555
2555
@@ -2610,14 +2610,14 @@ test('Buffered updates are reentrant - updatesAreReentrant', async (t) => {
2610
2610
makeActivation (
2611
2611
undefined ,
2612
2612
makeInitializeWorkflowJob ( workflowType ) ,
2613
- makeUpdateActivationJob ( '1' , '1' , 'non-existant' , 1 ) ,
2614
- makeUpdateActivationJob ( '2' , '2' , 'updateA' , 2 ) ,
2615
- makeUpdateActivationJob ( '3' , '3' , 'updateA' , 3 ) ,
2616
- makeUpdateActivationJob ( '4' , '4' , 'updateC' , 4 ) ,
2617
- makeUpdateActivationJob ( '5' , '5' , 'updateB' , 5 ) ,
2618
- makeUpdateActivationJob ( '6' , '6' , 'non-existant' , 6 ) ,
2619
- makeUpdateActivationJob ( '7' , '7' , 'updateB' , 7 ) ,
2620
- makeUpdateActivationJob ( '8' , '8' , 'updateC' , 8 )
2613
+ makeUpdateActivationJob ( '1' , '1' , 'non-existant' , [ 1 ] ) ,
2614
+ makeUpdateActivationJob ( '2' , '2' , 'updateA' , [ 2 ] ) ,
2615
+ makeUpdateActivationJob ( '3' , '3' , 'updateA' , [ 3 ] ) ,
2616
+ makeUpdateActivationJob ( '4' , '4' , 'updateC' , [ 4 ] ) ,
2617
+ makeUpdateActivationJob ( '5' , '5' , 'updateB' , [ 5 ] ) ,
2618
+ makeUpdateActivationJob ( '6' , '6' , 'non-existant' , [ 6 ] ) ,
2619
+ makeUpdateActivationJob ( '7' , '7' , 'updateB' , [ 7 ] ) ,
2620
+ makeUpdateActivationJob ( '8' , '8' , 'updateC' , [ 8 ] )
2621
2621
)
2622
2622
) ;
2623
2623
0 commit comments