diff --git a/brozzler/frontier.py b/brozzler/frontier.py index cd59a17..02f7f2d 100644 --- a/brozzler/frontier.py +++ b/brozzler/frontier.py @@ -91,7 +91,7 @@ class RethinkDbFrontier: def claim_site(self, worker_id): # XXX keep track of aggregate priority and prioritize sites accordingly? while True: - result = (self.r.table("sites") + result = (self.r.table("sites", read_mode="majority") .between( ["ACTIVE",rethinkdb.minval], ["ACTIVE",rethinkdb.maxval],