NewsBlur-viq/apps/search/tasks.py

from celery.task import Task

class IndexSubscriptionsForSearch(Task):
    
    def run(self, user_id):
        from apps.search.models import MUserSearch
        
        user_search = MUserSearch.get_user(user_id)
        user_search.index_subscriptions_for_search()
Adding task to index user's subscriptions and alert them to progress. 2014-04-16 11:57:49 -07:00			`from celery.task import Task`

			`class IndexSubscriptionsForSearch(Task):`

			`def run(self, user_id):`
Updating search indexing progress in real-time. 2014-04-16 15:31:44 -07:00			`from apps.search.models import MUserSearch`

			`user_search = MUserSearch.get_user(user_id)`
			`user_search.index_subscriptions_for_search()`