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

fix: differentiated interval and initial schedule call (#5896)

Browse Source 
Differentiate log lines so we can see if it happens on every call, or
just on the initial call.
This commit is contained in:
Christopher Kolstad 2024-01-15 12:50:32 +01:00 committed by GitHub
parent 22acadf4cc
commit 9d839299e2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/lib/features/maintenance/maintenance-service.ts
View File

@ -17,7 +17,7 @@ export default class MaintenanceService implements IMaintenanceStatus {
constructor(config: IUnleashConfig, settingService: SettingService) {
this.config = config;
this.logger = config.getLogger('services/pat-service.ts');
this.logger = config.getLogger('services/maintenance-service.ts');
this.settingService = settingService;
}

12
src/lib/features/scheduler/scheduler-service.test.ts
View File

@ -177,8 +177,8 @@ test('Can handle crash of a async job', async () => {
schedulerService.stop();
expect(getRecords()).toEqual([
['scheduled job failed | id: test-id-10 | async reason'],
['scheduled job failed | id: test-id-10 | async reason'],
['initial scheduled job failed | id: test-id-10 | async reason'],
['interval scheduled job failed | id: test-id-10 | async reason'],
]);
});
@ -197,8 +197,8 @@ test('Can handle crash of a sync job', async () => {
schedulerService.stop();
expect(getRecords()).toEqual([
['scheduled job failed | id: test-id-11 | Error: sync reason'],
['scheduled job failed | id: test-id-11 | Error: sync reason'],
['initial scheduled job failed | id: test-id-11 | Error: sync reason'],
['interval scheduled job failed | id: test-id-11 | Error: sync reason'],
]);
});
@ -217,8 +217,8 @@ test('Can handle crash of a async job', async () => {
schedulerService.stop();
expect(getRecords()).toEqual([
['scheduled job failed | id: test-id-10 | async reason'],
['scheduled job failed | id: test-id-10 | async reason'],
['initial scheduled job failed | id: test-id-10 | async reason'],
['interval scheduled job failed | id: test-id-10 | async reason'],
]);
});

6
src/lib/features/scheduler/scheduler-service.ts
View File

@ -52,7 +52,7 @@ export class SchedulerService {
}
} catch (e) {
this.logger.error(
`scheduled job failed | id: ${id} | ${e}`,
`interval scheduled job failed | id: ${id} | ${e}`,
);
}
}, timeMs).unref(),
@ -64,7 +64,9 @@ export class SchedulerService {
await runScheduledFunctionWithEvent();
}
} catch (e) {
this.logger.error(`scheduled job failed | id: ${id} | ${e}`);
this.logger.error(
`initial scheduled job failed | id: ${id} | ${e}`,
);
}
}

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

@ -101,8 +101,8 @@ test('Can handle crash of a async job', async () => {
schedulerService.stop();
expect(getRecords()).toEqual([
['scheduled job failed | id: test-id-10 | async reason'],
['scheduled job failed | id: test-id-10 | async reason'],
['initial scheduled job failed | id: test-id-10 | async reason'],
['interval scheduled job failed | id: test-id-10 | async reason'],
]);
});
@ -116,7 +116,7 @@ test('Can handle crash of a sync job', async () => {
schedulerService.stop();
expect(getRecords()).toEqual([
['scheduled job failed | id: test-id-11 | Error: sync reason'],
['scheduled job failed | id: test-id-11 | Error: sync reason'],
['initial scheduled job failed | id: test-id-11 | Error: sync reason'],
['interval scheduled job failed | id: test-id-11 | Error: sync reason'],
]);
});