from celery import shared_task
from celery.utils.log import get_task_logger

logger = get_task_logger(__name__)


@shared_task
def log(message):
    logger.info(message)

Add simple task to test integration of celery
Add simple task to test integration of celery

This adds a very simple logging task that just dumps and argument out to
the log. This can be used to setup a periodic task that will show that
all of the workers (worker, beat and celerycam) are working in harmony.
