(cfg *config.Configuration, err error)
| 178 | } |
| 179 | |
| 180 | func shouldRejectLockContentionImmediately(cfg *config.Configuration, err error) bool { |
| 181 | if cfg == nil || !cfg.Queue.RejectLockContentionImmediately { |
| 182 | return false |
| 183 | } |
| 184 | return hotpairs.IsLockContentionError(err) |
| 185 | } |
| 186 | |
| 187 | // indexData indexes data into TypeSense for searchability. |
| 188 | // It fetches the collection name and payload from the task, ensures the collections exist, |