fix(job_controller): add delay duration to log message when enqueueing job

This commit is contained in:
Hiroki Takatsuka 2024-04-07 16:42:48 +09:00 committed by GitHub
parent 9791f0d1f3
commit 84ffc2fc3d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -563,7 +563,7 @@ func (jm *Controller) enqueueSyncJobInternal(logger klog.Logger, obj interface{}
// all controllers there will still be some replica instability. One way to handle this is // all controllers there will still be some replica instability. One way to handle this is
// by querying the store for all controllers that this rc overlaps, as well as all // by querying the store for all controllers that this rc overlaps, as well as all
// controllers that overlap this rc, and sorting them. // controllers that overlap this rc, and sorting them.
logger.Info("enqueueing job", "key", key) logger.Info("enqueueing job", "key", key, "delay", delay)
jm.queue.AddAfter(key, delay) jm.queue.AddAfter(key, delay)
} }