Skip to content

Commit 46347b8

Browse files
committed
test: update test to expect all messages retried on unhandled error
1 parent 40feda1 commit 46347b8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lambdas/functions/control-plane/src/lambda.test.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,9 @@ describe('Test scale up lambda wrapper.', () => {
215215
vi.mocked(scaleUp).mockRejectedValue(new Error('Generic error'));
216216

217217
const result = await scaleUpHandler(multiRecordEvent, context);
218-
expect(result).toEqual({ batchItemFailures: [] });
218+
expect(result).toEqual({
219+
batchItemFailures: [{ itemIdentifier: 'message-0' }, { itemIdentifier: 'message-1' }],
220+
});
219221
});
220222

221223
it('Should throw when scaleUp throws ScaleError', async () => {

0 commit comments

Comments
 (0)