@@ -8,7 +8,7 @@ import { scaleDown } from './scale-runners/scale-down';
88import { ActionRequestMessage , scaleUp } from './scale-runners/scale-up' ;
99import { cleanSSMTokens } from './scale-runners/ssm-housekeeper' ;
1010import { checkAndRetryJob } from './scale-runners/job-retry' ;
11- import { describe , it , expect , vi , MockedFunction } from 'vitest' ;
11+ import { describe , it , expect , vi , MockedFunction , beforeEach } from 'vitest' ;
1212
1313const body : ActionRequestMessage = {
1414 eventType : 'workflow_job' ,
@@ -160,9 +160,7 @@ describe('Test scale up lambda wrapper.', () => {
160160 const records = createMultipleRecords ( 3 ) ;
161161 const multiRecordEvent : SQSEvent = { Records : records } ;
162162
163- const mock = vi . fn ( scaleUp ) ;
164- mock . mockImplementation ( ( ) => Promise . resolve ( [ 'message-1' , 'message-2' ] ) ) ;
165- vi . mocked ( scaleUp ) . mockImplementation ( mock ) ;
163+ vi . mocked ( scaleUp ) . mockResolvedValue ( [ 'message-1' , 'message-2' ] ) ;
166164
167165 const result = await scaleUpHandler ( multiRecordEvent , context ) ;
168166 expect ( result ) . toEqual ( {
@@ -243,9 +241,7 @@ describe('Test scale up lambda wrapper.', () => {
243241 const multiRecordEvent : SQSEvent = { Records : records } ;
244242
245243 const error = new ScaleError ( 2 ) ;
246- const mock = vi . fn ( scaleUp ) ;
247- mock . mockImplementation ( ( ) => Promise . reject ( error ) ) ;
248- vi . mocked ( scaleUp ) . mockImplementation ( mock ) ;
244+ vi . mocked ( scaleUp ) . mockRejectedValue ( error ) ;
249245
250246 await expect ( scaleUpHandler ( multiRecordEvent , context ) ) . resolves . toEqual ( {
251247 batchItemFailures : [ { itemIdentifier : 'message-0' } , { itemIdentifier : 'message-1' } ] ,
0 commit comments