diff --git a/server/worker.go b/server/worker.go index 009d6e6..a22e7b0 100644 --- a/server/worker.go +++ b/server/worker.go @@ -200,11 +200,11 @@ func updateWorkerTaskStatus(ctx context.Context) { var ts types.TaskStatus _, err := rpcServer.Call(ctx, w.Conn, "task-status", tsr, &ts) 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) if err != nil { - slog.ErrorContext(ctx, "Error Updating Unknown Task Status", "err", err) + slog.ErrorContext(ctx, "Updating Unknown Task Status", "err", err) 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) if err != nil { - slog.ErrorContext(ctx, "Error Updating Task Status", "err", err) + slog.ErrorContext(ctx, "Updating Task Status", "err", err) 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) if err != nil { - slog.ErrorContext(ctx, "Error Updating File health", "err", err) + slog.ErrorContext(ctx, "Updating File health", "err", err) 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 { _, err := rpcServer.Call(ctx, w.Conn, "task-delete", ts.Task.ID, 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 } }