jeffemmett
/
postiz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add expiration for stuck jobs

This commit is contained in:
Nevo David 2025-08-07 23:42:03 +07:00
parent 0d231545ec
commit 889a031e0e
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
libraries/helpers/src/utils/concurrency.service.ts
View File

@ -23,15 +23,18 @@ export const concurrency = async <T>(
});
let load: T;
try {
load = await mapper[strippedIdentifier].schedule<T>(async () => {
return await Promise.race<T>([
new Promise<T>(async (res) => {
await timer(300000);
res(true as T);
}),
func(),
]);
});
load = await mapper[strippedIdentifier].schedule<T>(
{ expiration: 600000 },
async () => {
return await Promise.race<T>([
new Promise<T>(async (res) => {
await timer(300000);
res(true as T);
}),
func(),
]);
}
);
} catch (err) {}
return load;