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

Remove Redundant Error

Browse source
This commit is contained in:
speatzle 2024-05-21 16:22:22 +02:00
parent df80f935bd
commit 4c1e29265e
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
server/worker.go
View file

@ -200,11 +200,11 @@ func updateWorkerTaskStatus(ctx context.Context) {
var ts types.TaskStatus var ts types.TaskStatus
_, err := rpcServer.Call(ctx, w.Conn, "task-status", tsr, &ts) _, err := rpcServer.Call(ctx, w.Conn, "task-status", tsr, &ts)
if err != nil { if err != nil {
slog.ErrorContext(ctx, "Error Getting Task Status", "err", err) slog.ErrorContext(ctx, "Getting Task Status", "err", err)
_, err = db.Exec(ctx, "UPDATE tasks SET status = $2 WHERE id = $1", ts.Task.ID, constants.TASK_STATUS_UNKNOWN) _, err = db.Exec(ctx, "UPDATE tasks SET status = $2 WHERE id = $1", ts.Task.ID, constants.TASK_STATUS_UNKNOWN)
if err != nil { if err != nil {
slog.ErrorContext(ctx, "Error Updating Unknown Task Status", "err", err) slog.ErrorContext(ctx, "Updating Unknown Task Status", "err", err)
return return
} }
@ -213,7 +213,7 @@ func updateWorkerTaskStatus(ctx context.Context) {
_, err = db.Exec(ctx, "UPDATE tasks SET status = $2, log = log || $3 WHERE id = $1", ts.Task.ID, ts.Task.Status, ts.Task.Log) _, err = db.Exec(ctx, "UPDATE tasks SET status = $2, log = log || $3 WHERE id = $1", ts.Task.ID, ts.Task.Status, ts.Task.Log)
if err != nil { if err != nil {
slog.ErrorContext(ctx, "Error Updating Task Status", "err", err) slog.ErrorContext(ctx, "Updating Task Status", "err", err)
return return
} }
@ -227,7 +227,7 @@ func updateWorkerTaskStatus(ctx context.Context) {
} }
_, err = db.Exec(ctx, "UPDATE files SET health = $2 WHERE id = $1", ts.Task.FileID, health) _, err = db.Exec(ctx, "UPDATE files SET health = $2 WHERE id = $1", ts.Task.FileID, health)
if err != nil { if err != nil {
slog.ErrorContext(ctx, "Error Updating File health", "err", err) slog.ErrorContext(ctx, "Updating File health", "err", err)
return return
} }
} }
@ -236,7 +236,7 @@ func updateWorkerTaskStatus(ctx context.Context) {
if ts.Task.Status == constants.TASK_STATUS_FAILED || ts.Task.Status == constants.TASK_STATUS_SUCCESS { if ts.Task.Status == constants.TASK_STATUS_FAILED || ts.Task.Status == constants.TASK_STATUS_SUCCESS {
_, err := rpcServer.Call(ctx, w.Conn, "task-delete", ts.Task.ID, nil) _, err := rpcServer.Call(ctx, w.Conn, "task-delete", ts.Task.ID, nil)
if err != nil { if err != nil {
slog.ErrorContext(ctx, "Error Deleting Finished Task From Worker", "err", err) slog.ErrorContext(ctx, "Deleting Finished Task From Worker", "err", err)
return return
} }
} }