Fix expire call.

main
Vincent Driessen 13 years ago
parent 374c95f7a2
commit 606f7f7cb3

@ -15,4 +15,7 @@ def queue_daemon(app, queue_keys, rv_ttl=500):
except Exception, e:
rv = e
if rv is not None:
conn.setex(key, rv_ttl, dumps(rv))
p = conn.pipeline()
conn.set(key, dumps(rv))
conn.expire(key, rv_ttl)
p.execute()

Loading…
Cancel
Save