From bb4028f0ac1c271e5c171e596f7b8e5804d42054 Mon Sep 17 00:00:00 2001
From: =?utf8?q?Stefan=20K=C3=B6gl?= <stefan@skoegl.net>
Date: Sat, 27 Apr 2013 13:48:28 +0200
Subject: [PATCH] add some stale='update_after' for better performance

---
 mygpo/db/couchdb/episode_state.py | 5 +++++
 mygpo/db/couchdb/user.py          | 4 ++++
 2 files changed, 9 insertions(+)

diff --git a/mygpo/db/couchdb/episode_state.py b/mygpo/db/couchdb/episode_state.py
index 549b2034..b03ba24d 100644
--- a/mygpo/db/couchdb/episode_state.py
+++ b/mygpo/db/couchdb/episode_state.py
@@ -97,6 +97,7 @@ def podcast_listener_count(episode):
             group       = True,
             group_level = 1,
             reduce      = True,
+            stale       = 'update_after',
         )
     return r.first()['value'] if r else 0
 
@@ -120,6 +121,7 @@ def podcast_listener_count_timespan(podcast, start=None, end={}):
             group       = True,
             group_level = 2,
             reduce      = True,
+            stale       = 'update_after',
         )
 
     return map(_wrap_listener_count, r)
@@ -139,6 +141,7 @@ def episode_listener_counts(episode):
             group       = True,
             group_level = 2,
             reduce      = True,
+            stale       = 'update_after',
         )
 
     return map(_wrap_listeners, r)
@@ -179,6 +182,7 @@ def episode_listener_count(episode, start=None, end={}):
             group       = True,
             group_level = 2,
             reduce      = True,
+            stale       = 'update_after',
         )
     return r.first()['value'] if r else 0
 
@@ -204,6 +208,7 @@ def episode_listener_count_timespan(episode, start=None, end={}):
             group       = True,
             group_level = 3,
             reduce      = True,
+            stale       = 'update_after',
         )
 
     return map(_wrap_listener_count, r)
diff --git a/mygpo/db/couchdb/user.py b/mygpo/db/couchdb/user.py
index d82ce2e6..d2cf7263 100644
--- a/mygpo/db/couchdb/user.py
+++ b/mygpo/db/couchdb/user.py
@@ -23,6 +23,7 @@ def get_num_listened_episodes(user):
             endkey      = [user._id, {}],
             reduce      = True,
             group_level = 2,
+            stale       = 'update_after',
         )
 
     return map(_wrap_num_listened, r)
@@ -52,6 +53,7 @@ def get_num_played_episodes(user, since=None, until={}):
             startkey = startkey,
             endkey   = endkey,
             reduce   = True,
+            stale    = 'update_after',
         )
 
     val = res.one()
@@ -78,6 +80,7 @@ def get_latest_episodes(user, count=10):
             descending   = True,
             limit        = count,
             reduce       = False,
+            stale        = 'update_after',
         )
 
     keys = [r['value'] for r in res]
@@ -105,6 +108,7 @@ def get_seconds_played(user, since=None, until={}):
             startkey = startkey,
             endkey   = endkey,
             reduce   = True,
+            stale    = 'update_after',
         )
 
     val = res.one()
-- 
2.11.4.GIT