view core/tasks.py @ 629:f4c043cf55ac

Wiki integration. Requests don't always have sessions. In particular this occurs when a request is made without a trailing slash. The Common middleware redirects when this happens, and the middleware process_request() processing stops before a session can get added. So just set an attribute on the request object for each operation. This seemed weird to me at first, but there are plenty of examples of this in the Django code base already.
author Brian Neal <bgneal@gmail.com>
date Tue, 13 Nov 2012 13:50:06 -0600
parents ee87ea74d46b
children 53a56d19568c
line wrap: on
line source
"""
Celery tasks for the core application.

"""
from celery.task import task
import django.core.mail

import core.whos_online


@task
def add(x, y):
    """
    It is useful to have a test task laying around. This is it.

    """
    return x + y


@task
def send_mail(subject, message, from_email, recipient_list, **kwargs):
    """
    A task to send mail via Django.

    """
    django.core.mail.send_mail(subject, message, from_email, recipient_list,
            **kwargs)


@task
def cleanup():
    """
    A task to perform site-wide cleanup actions.

    """
    # These imports, when placed at the top of the module, caused all kinds of
    # import problems when running on the production server (Python 2.5 and
    # mod_wsgi). Moving them here worked around that problem.

    from django.core.management.commands.cleanup import Command as CleanupCommand
    from forums.management.commands.forum_cleanup import Command as ForumCleanup

    # Execute Django's cleanup command (deletes old sessions).

    command = CleanupCommand()
    command.execute()

    # Execute our forum cleanup command to delete old last visit records.

    command = ForumCleanup()
    command.execute()


@task
def max_users():
    """
    Run the periodic task to calculate the who's online max users/visitors
    statistics.

    """
    core.whos_online.max_users()