Forcing read pref on user search check.

This commit is contained in:
Samuel Clay 2014-04-23 11:33:56 -07:00
parent 28d51309ce
commit 74e7bfb2c9

View file

@ -1,5 +1,6 @@
import time import time
import datetime import datetime
import pymongo
import pyes import pyes
import redis import redis
import celery import celery
@ -29,7 +30,8 @@ class MUserSearch(mongo.Document):
@classmethod @classmethod
def get_user(cls, user_id): def get_user(cls, user_id):
try: try:
user_search = cls.objects.get(user_id=user_id) user_search = cls.objects.read_preference(pymongo.ReadPreference.PRIMARY)\
.get(user_id=user_id)
except cls.DoesNotExist: except cls.DoesNotExist:
user_search = cls.objects.create(user_id=user_id) user_search = cls.objects.create(user_id=user_id)
@ -37,9 +39,9 @@ class MUserSearch(mongo.Document):
def touch_search_date(self): def touch_search_date(self):
# Blackout # Blackout
# if not self.subscriptions_indexed and not self.subscriptions_indexing: if not self.subscriptions_indexed and not self.subscriptions_indexing:
# self.schedule_index_subscriptions_for_search() self.schedule_index_subscriptions_for_search()
# self.subscriptions_indexing = True self.subscriptions_indexing = True
self.last_search_date = datetime.datetime.now() self.last_search_date = datetime.datetime.now()
self.save() self.save()