diff --git a/task.go b/task.go index 966bf66..541820c 100644 --- a/task.go +++ b/task.go @@ -28,7 +28,7 @@ func (i Instance) RunTask(typename string, payload []byte, priority string, retr options = append(options, asynq.MaxRetry(retryTimes)) // Task timeout - if i.Config.TaskTimeout != 0 { + if i.Config.TaskTimeout > 0 { options = append(options, asynq.Timeout(i.Config.TaskTimeout)) }