Herman/Yiqun
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

check already started and do not do repeated work

Browse Source
This commit is contained in:
HermanL02
2025-05-01 16:37:12 -03:00
parent c6655e7c71
commit e5649c19cb
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
worker/src/task/1-task.ts
View File

@ -147,11 +147,14 @@ export async function task(roundNumber: number): Promise<void> {
const requiredWorkResponseData = await requiredWorkResponse.json(); const requiredWorkResponseData = await requiredWorkResponse.json();
console.log("[TASK] requiredWorkResponseData: ", requiredWorkResponseData); console.log("[TASK] requiredWorkResponseData: ", requiredWorkResponseData);
const uuid = uuidv4(); const uuid = uuidv4();
const alreadyAssigned = await namespaceWrapper.storeGet(JSON.stringify(requiredWorkResponseData.data.id));
if (alreadyAssigned) {
await namespaceWrapper.storeSet(`result-${roundNumber}`, status.NOT_FINISHED_TASK);
return;
}else{
await namespaceWrapper.storeSet(JSON.stringify(requiredWorkResponseData.data.id), "true");
}
// await namespaceWrapper.storeSet(`work-info`, JSON.stringify({
// ...requiredWorkResponseData.data,
// round: roundNumber
// }));
await namespaceWrapper.storeSet(`uuid-${roundNumber}`, uuid); await namespaceWrapper.storeSet(`uuid-${roundNumber}`, uuid);
const podcallPayload = { const podcallPayload = {