This document is for Celery's development version, which can be significantly different from previous releases. Get old docs here: 2.5.

celery.task.sets

class celery.task.sets.TaskSet(tasks=None, app=None, Publisher=None)

A task containing several subtasks, making it possible to track how many, or when all of the tasks have been completed.

Parameters:tasks – A list of subtask instances.

Example:

>>> urls = ("http://cnn.com/rss", "http://bbc.co.uk/rss")
>>> s = TaskSet(refresh_feed.s(url) for url in urls)
>>> taskset_result = s.apply_async()
>>> list_of_return_values = taskset_result.join()  # *expensive*

app = None

apply(taskset_id=None)

Applies the TaskSet locally by blocking until all tasks return.

apply_async(connection=None, connect_timeout=None, publisher=None, taskset_id=None)

Apply TaskSet.

tasks