speatzle/morffix
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

Prevent Starting Task Twice

Browse source
This commit is contained in:
Samuel Lorch 2024-07-06 03:07:06 +02:00
parent b99a818040
commit c37c26908d
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
constants/error.go
View file

@ -3,3 +3,4 @@ package constants
import "fmt" import "fmt"
var ErrTaskDoesNotExist = fmt.Errorf("Task does not Exist") var ErrTaskDoesNotExist = fmt.Errorf("Task does not Exist")
var ErrTaskIsAlreadyRunning = fmt.Errorf("Task is Already Running")

5
task/task.go
View file

@ -17,6 +17,11 @@ func StartTask(conf config.Config, data types.TaskStart) error {
taskMutex.Lock() taskMutex.Lock()
defer taskMutex.Unlock() defer taskMutex.Unlock()
_, ok := tasks[data.ID]
if ok {
return constants.ErrTaskIsAlreadyRunning
}
tasks[data.ID] = &types.Task{ tasks[data.ID] = &types.Task{
ID: data.ID, ID: data.ID,
Type: data.Type, Type: data.Type,