wizardchen
0e1282c2da
Centralize DefaultDocumentProcessTimeout in the config package and reuse DocumentProcessTimeout() from documentProcessTaskOptions.
16 lines
348 B
Go
16 lines
348 B
Go
package service
|
|
|
|
import (
|
|
"github.com/Tencent/WeKnora/internal/config"
|
|
"github.com/hibiken/asynq"
|
|
)
|
|
|
|
func documentProcessTaskOptions(cfg *config.Config, extra ...asynq.Option) []asynq.Option {
|
|
opts := []asynq.Option{
|
|
asynq.Queue("default"),
|
|
asynq.Timeout(config.DocumentProcessTimeout(cfg)),
|
|
}
|
|
opts = append(opts, extra...)
|
|
return opts
|
|
}
|