@@ -45,12 +45,13 @@ describe('Test sending message to SQS.', () => {
45
45
QueueUrl : queueUrl ,
46
46
MessageBody : JSON . stringify ( no_fifo_message ) ,
47
47
} ;
48
+
48
49
// Act
49
- const result = await sendActionRequest ( no_fifo_message ) ;
50
+ const result = sendActionRequest ( no_fifo_message ) ;
50
51
51
52
// Assert
52
- expect ( mockSQS . sendMessage ) . toBeCalledWith ( sqsMessage ) ;
53
- expect ( result ) . resolves ;
53
+ expect ( mockSQS . sendMessage ) . toHaveBeenCalledWith ( sqsMessage ) ;
54
+ await expect ( result ) . resolves . not . toThrow ( ) ;
54
55
} ) ;
55
56
56
57
it ( 'use a fifo queue' , async ( ) => {
@@ -64,11 +65,11 @@ describe('Test sending message to SQS.', () => {
64
65
MessageBody : JSON . stringify ( fifo_message ) ,
65
66
} ;
66
67
// Act
67
- const result = await sendActionRequest ( fifo_message ) ;
68
+ const result = sendActionRequest ( fifo_message ) ;
68
69
69
70
// Assert
70
- expect ( mockSQS . sendMessage ) . toBeCalledWith ( { ...sqsMessage , MessageGroupId : String ( message . id ) } ) ;
71
- expect ( result ) . resolves ;
71
+ expect ( mockSQS . sendMessage ) . toHaveBeenCalledWith ( { ...sqsMessage , MessageGroupId : String ( message . id ) } ) ;
72
+ await expect ( result ) . resolves . not . toThrow ( ) ;
72
73
} ) ;
73
74
} ) ;
74
75
@@ -94,11 +95,11 @@ describe('Test sending message to SQS.', () => {
94
95
const config = await Config . load ( ) ;
95
96
96
97
// Act
97
- const result = await sendWebhookEventToWorkflowJobQueue ( message , config ) ;
98
+ const result = sendWebhookEventToWorkflowJobQueue ( message , config ) ;
98
99
99
100
// Assert
100
101
expect ( mockSQS . sendMessage ) . toHaveBeenCalledWith ( sqsMessage ) ;
101
- expect ( result ) . resolves ;
102
+ await expect ( result ) . resolves . not . toThrow ( ) ;
102
103
} ) ;
103
104
104
105
it ( 'Does not send webhook events to workflow job event copy queue when job queue is not in environment' , async ( ) => {
0 commit comments