Function TestShouldRejectLockContentionImmediately

cmd/workers_test.go:36–55

(t *testing.T)

}

func TestShouldRejectLockContentionImmediately(t *testing.T) {
	cfg := &config.Configuration{
		Queue: config.QueueConfig{
			RejectLockContentionImmediately: true,
		},
	}

	if !shouldRejectLockContentionImmediately(cfg, fmt.Errorf("failed to acquire lock: already held")) {
		t.Fatal("expected lock contention to reject immediately when enabled")
	}

	if shouldRejectLockContentionImmediately(cfg, fmt.Errorf("random transient database error")) {
		t.Fatal("expected non-lock error not to reject immediately")
	}

	cfg.Queue.RejectLockContentionImmediately = false
	if shouldRejectLockContentionImmediately(cfg, fmt.Errorf("failed to acquire lock: already held")) {
		t.Fatal("expected lock contention not to reject immediately when disabled")
	}
}