go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-26 07:42:17 +08:00
Code Issues Projects Releases Wiki Activity

[ci skip] Fix typos

Browse Source
This commit is contained in:
Ken Hibino 2019-12-08 14:17:57 -08:00
parent 680a2cf3df
commit bbd8fb901f
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/rdb/inspect.go
View File

@ -225,8 +225,8 @@ func (r *RDB) ListDead() ([]*DeadTask, error) {
} }
// Rescue finds a task that matches the given id and score from dead queue // Rescue finds a task that matches the given id and score from dead queue
// and enqueues it processing. If a task that maches the id and score does // and enqueues it for processing. If a task that matches the id and score
// not exist, it returns ErrTaskNotFound. // does not exist, it returns ErrTaskNotFound.
func (r *RDB) Rescue(id string, score float64) error { func (r *RDB) Rescue(id string, score float64) error {
n, err := r.removeAndEnqueue(deadQ, id, score) n, err := r.removeAndEnqueue(deadQ, id, score)
if err != nil { if err != nil {
@ -239,8 +239,8 @@ func (r *RDB) Rescue(id string, score float64) error {
} }
// RetryNow finds a task that matches the given id and score from retry queue // RetryNow finds a task that matches the given id and score from retry queue
// and enqueues it for processing. If a task that maches the id and score does // and enqueues it for processing. If a task that matches the id and score
// not exist, it returns ErrTaskNotFound. // does not exist, it returns ErrTaskNotFound.
func (r *RDB) RetryNow(id string, score float64) error { func (r *RDB) RetryNow(id string, score float64) error {
n, err := r.removeAndEnqueue(retryQ, id, score) n, err := r.removeAndEnqueue(retryQ, id, score)
if err != nil { if err != nil {
@ -253,7 +253,7 @@ func (r *RDB) RetryNow(id string, score float64) error {
} }
// ProcessNow finds a task that matches the given id and score from scheduled queue // ProcessNow finds a task that matches the given id and score from scheduled queue
// and enqueues it for processing. If a task that maches the id and score does not // and enqueues it for processing. If a task that matches the id and score does not
// exist, it returns ErrTaskNotFound. // exist, it returns ErrTaskNotFound.
func (r *RDB) ProcessNow(id string, score float64) error { func (r *RDB) ProcessNow(id string, score float64) error {
n, err := r.removeAndEnqueue(scheduledQ, id, score) n, err := r.removeAndEnqueue(scheduledQ, id, score)