NewsBlur/apps/analyzer/tasks.py

from celery.task import Task
from utils import log as logging

class EmailPopularityQuery(Task):
    
    def run(self, pk):
        from apps.analyzer.models import MPopularityQuery
        
        query = MPopularityQuery.objects.get(pk=pk)
        logging.debug(" -> ~BB~FCRunning popularity query: ~SB%s" % query)
        
        query.send_email()
Adding popularity query email. 2017-01-05 18:26:50 -08:00			`from celery.task import Task`
			`from utils import log as logging`

			`class EmailPopularityQuery(Task):`

			`def run(self, pk):`
			`from apps.analyzer.models import MPopularityQuery`

			`query = MPopularityQuery.objects.get(pk=pk)`
Fixing keyword popularity task. 2017-01-05 18:29:28 -08:00			`logging.debug(" -> ~BB~FCRunning popularity query: ~SB%s" % query)`
Adding popularity query email. 2017-01-05 18:26:50 -08:00
			`query.send_email()`