go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-10-21 21:46:12 +08:00
Code Issues Projects Releases Wiki Activity

Update RDB.RunTask with task state

Browse Source
This commit is contained in:
Ken Hibino
2021-04-28 07:27:35 -07:00
parent b8cd3e307d
commit 011669a3e8
4 changed files with 55 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
inspeq/inspector.go
View File

@@ -613,11 +613,11 @@ func (i *Inspector) RunTaskByKey(qname, key string) error {
}
switch prefix {
case keyPrefixScheduled:
return i.rdb.RunScheduledTask(qname, id)
return i.rdb.RunTask(qname, id)
case keyPrefixRetry:
return i.rdb.RunRetryTask(qname, id)
return i.rdb.RunTask(qname, id)
case keyPrefixArchived:
return i.rdb.RunArchivedTask(qname, id)
return i.rdb.RunTask(qname, id)
case keyPrefixPending:
return fmt.Errorf("task is already pending for run")
default: