diff --git a/tools/asynq/cmd/task.go b/tools/asynq/cmd/task.go index 45ed6e0..6c7d0a6 100644 --- a/tools/asynq/cmd/task.go +++ b/tools/asynq/cmd/task.go @@ -520,6 +520,8 @@ func taskDeleteAll(cmd *cobra.Command, args []string) { n, err = i.DeleteAllRetryTasks(qname) case "archived": n, err = i.DeleteAllArchivedTasks(qname) + case "completed": + n, err = i.DeleteAllCompletedTasks(qname) default: fmt.Printf("error: unsupported state %q\n", state) os.Exit(1)