zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(worker): avoid workers getting blocked

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-09-13 17:50:13 +02:00
parent efd24ca67a
commit 447f303aa4
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
apps/worker/src/jobs/events.incoming-event.ts
View File

@@ -183,6 +183,10 @@ function getSessionEndWithPriority(
return async (args) => { return async (args) => {
const res = await getSessionEnd(args); const res = await getSessionEnd(args);
if (count > 10) {
throw new Error('Failed to get session end');
}
// if we get simultaneous requests we want to avoid race conditions with getting the session end // if we get simultaneous requests we want to avoid race conditions with getting the session end
// one of the events will get priority and the other will wait for the first to finish // one of the events will get priority and the other will wait for the first to finish
if (res === null && priority === false) { if (res === null && priority === false) {
@@ -190,10 +194,6 @@ function getSessionEndWithPriority(
return getSessionEndWithPriority(priority, count + 1)(args); return getSessionEndWithPriority(priority, count + 1)(args);
} }
if (count > 10) {
throw new Error('Failed to get session end');
}
return res; return res;
}; };
} }