peridot/peridot
7
0
Fork 0
mirror of https://github.com/peridotbuild/peridot.git synced 2024-10-08 08:54:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

If entry ID is not set, delete entry for failed entries

Browse Source
This commit is contained in:
Mustafa Gezen 2023-09-06 23:29:43 +02:00
parent a7332a640b
commit 847abe2258
Signed by: mustafa
GPG Key ID: DCDF010D946438C1
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tools/mothership/worker_server/workflows.go
View File

@ -179,6 +179,12 @@ func ProcessRPMWorkflow(ctx workflow.Context, args *mothershippb.ProcessRPMArgs)
MaximumAttempts: 0,
},
})
// Check if entry has EntryID set, if not then we can just delete the entry
if entry.EntryId == "" {
_ = workflow.ExecuteActivity(ctx, w.DeleteEntry, entry.Name).Get(ctx, nil)
return
}
_ = workflow.ExecuteActivity(ctx, w.SetEntryState, entry.Name, mothershippb.Entry_FAILED, nil).Get(ctx, nil)
}()