Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-06-04 01:18:20 +02:00
Code Issues Projects Releases Wiki Activity

test: increase timer values in scheduler integration test (#3448)

Browse Source
This commit is contained in:
Mateusz Kwasniewski 2023-04-04 14:15:45 +02:00 committed by GitHub
parent d65a357a69
commit c16fde5ab4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/lib/services/scheduler-service.test.ts
View File

@ -5,7 +5,7 @@ function ms(timeMs) {
} }
const getLogger = () => { const getLogger = () => {
const records = []; const records: any[] = [];
const logger = () => ({ const logger = () => ({
error(...args: any[]) { error(...args: any[]) {
records.push(args); records.push(args);
@ -37,8 +37,8 @@ test('Can schedule a single regular job', async () => {
const schedulerService = new SchedulerService(getLogger()); const schedulerService = new SchedulerService(getLogger());
const job = jest.fn(); const job = jest.fn();
schedulerService.schedule(job, 10); schedulerService.schedule(job, 50);
await ms(15); await ms(75);
expect(job).toBeCalledTimes(2); expect(job).toBeCalledTimes(2);
schedulerService.stop(); schedulerService.stop();
@ -49,9 +49,9 @@ test('Can schedule multiple jobs at the same interval', async () => {
const job = jest.fn(); const job = jest.fn();
const anotherJob = jest.fn(); const anotherJob = jest.fn();
schedulerService.schedule(job, 10); schedulerService.schedule(job, 50);
schedulerService.schedule(anotherJob, 10); schedulerService.schedule(anotherJob, 50);
await ms(15); await ms(75);
expect(job).toBeCalledTimes(2); expect(job).toBeCalledTimes(2);
expect(anotherJob).toBeCalledTimes(2); expect(anotherJob).toBeCalledTimes(2);
@ -79,8 +79,8 @@ test('Can handle crash of a async job', async () => {
await Promise.reject('async reason'); await Promise.reject('async reason');
}; };
schedulerService.schedule(job, 10); schedulerService.schedule(job, 50);
await ms(15); await ms(75);
schedulerService.stop(); schedulerService.stop();
expect(logger.getRecords()).toEqual([ expect(logger.getRecords()).toEqual([
@ -96,8 +96,8 @@ test('Can handle crash of a sync job', async () => {
throw new Error('sync reason'); throw new Error('sync reason');
}; };
schedulerService.schedule(job, 10); schedulerService.schedule(job, 50);
await ms(15); await ms(75);
schedulerService.stop(); schedulerService.stop();
expect(logger.getRecords()).toEqual([ expect(logger.getRecords()).toEqual([