|
|
|
@ -1248,14 +1248,12 @@
@@ -1248,14 +1248,12 @@
|
|
|
|
|
:if-does-not-exist :create |
|
|
|
|
:if-exists :append) |
|
|
|
|
(dolist (key keys) |
|
|
|
|
(if (and (or (and |
|
|
|
|
(uiop:string-prefix-p "X" key) |
|
|
|
|
(> (redis-last-score key) |
|
|
|
|
(- (get-universal-time) *xr-train-rescue-secs*))) |
|
|
|
|
(> (redis-last-score key) |
|
|
|
|
(- (get-universal-time) *train-active-expiry-secs-real*))) |
|
|
|
|
(< (redis-sorted-set-length key) *train-live-data-limit*) |
|
|
|
|
(not archive-all)) |
|
|
|
|
(if (and |
|
|
|
|
(not (uiop:string-prefix-p "X" key)) |
|
|
|
|
(> (redis-last-score key) |
|
|
|
|
(- (get-universal-time) *train-active-expiry-secs-real*)) |
|
|
|
|
(< (redis-sorted-set-length key) *train-live-data-limit*) |
|
|
|
|
(not archive-all)) |
|
|
|
|
(handler-case |
|
|
|
|
(multiple-value-bind (new-code dist path timediff) |
|
|
|
|
(maybe-rescue-train key) |
|
|
|
|