celery/celery/tests/functional/tasks.py

from __future__ import absolute_import

import time

from celery.task import task
from celery.task.sets import subtask


@task
def add(x, y):
    return x + y


@task
def add_cb(x, y, callback=None):
    result = x + y
    if callback:
        return subtask(callback).apply_async(result)
    return result


@task
def sleeptask(i):
    time.sleep(i)
    return i