analytics-tasks.py

import logging

from myapp.celery_config import celery_app
from myapp.corporations.models import Corporation

logger = logging.getLogger()


@celery_app.task(
    name='analytics.update_corporation_data',
    queue='whenever',
    ignore_result=True,
)
def update_corporation_data(corp_pk):
    corporation = Corporation.objects.get(pk=corp_pk)
    logger.info(u'Updating stored data for %s (pk: %s)' % (
        corporation, corporation.pk))

    corporation.update_data()


@celery_app.task(
    name='analytics.update_all_corporations',
    queue='whenever',
    ignore_result=True
)
def update_all_corporations():
    for corporation in Corporation.objects.all():
        update_corporation_data.apply_async(args=(corporation.pk,))