diff options
| -rw-r--r-- | mumi/jobs.scm | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/mumi/jobs.scm b/mumi/jobs.scm index 69ef2b2..c4aca00 100644 --- a/mumi/jobs.scm +++ b/mumi/jobs.scm @@ -63,9 +63,11 @@ (define get-status (make-getter "status")) (define (set-status! item status) - (set (list (string-append %prefix "status:" item) - (string-append status ":" - (number->string (current-time)))))) + (let ((key (string-append %prefix "status:" item))) + (with-redis + (transaction + (set (list key status)) + (expire (list key (* 60 60 24 30))))))) ;delete after a month (define (next-waiting) "Wait for an item to appear on the waiting list, then move it to |