diff --git a/__init__.py b/__init__.py index a6cbe64..19cee28 100644 --- a/__init__.py +++ b/__init__.py @@ -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()