go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-20 07:40:19 +08:00
Code Issues Projects Releases Wiki Activity

warn user when they set a big number of janitor batch size

Browse Source
This commit is contained in:
Agung Hariadi Tedja 2023-08-08 09:54:42 +07:00
parent 0db497a8e0
commit b4676d1af5
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server.go
View File

@ -554,6 +554,10 @@ func NewServer(r RedisConnOpt, cfg Config) *Server {
if janitorBatchSize == 0 { if janitorBatchSize == 0 {
janitorBatchSize = defaultJanitorBatchSize janitorBatchSize = defaultJanitorBatchSize
} }
if janitorBatchSize > defaultJanitorBatchSize {
logger.Warnf("Janitor batch size of %d is greater than the recommended batch size of %d. "+
"This might cause a long-running script", janitorBatchSize, defaultJanitorBatchSize)
}
janitor := newJanitor(janitorParams{ janitor := newJanitor(janitorParams{
logger: logger, logger: logger,
broker: rdb, broker: rdb,