django_celery_results.managers
¶
Model managers.
- class django_celery_results.managers.GroupResultManager(*args, **kwargs)[source]¶
Manager for
celery.models.GroupResult
models.
- class django_celery_results.managers.ResultManager(*args, **kwargs)[source]¶
Generic manager for celery results.
- class django_celery_results.managers.TaskResultManager(*args, **kwargs)[source]¶
Manager for
celery.models.TaskResult
models.- get_task(task_id)[source]¶
Get result for task by
task_id
.- exception_retry_count (int): How many times to retry by
transaction rollback on exception. This could happen in a race condition if another worker is trying to create the same task. The default is to retry once.
- store_result(content_type, content_encoding, task_id, result, status, traceback=None, meta=None, task_name=None, task_args=None, task_kwargs=None, worker=None, using=None)[source]¶
Store the result and status of a task.
content_type (str): Mime-type of result and meta content. content_encoding (str): Type of encoding (e.g. binary/utf-8). task_id (str): Id of task. task_name (str): Celery task name. task_args (str): Task arguments. task_kwargs (str): Task kwargs. result (str): The serialized return value of the task,
or an exception instance raised by the task.
- status (str): Task status. See
celery.states
for a list of possible status values.
worker (str): Worker that executes the task. using (str): Django database connection to use. traceback (str): The traceback string taken at the point of
exception (only passed if the task failed).
- meta (str): Serialized result meta data (this contains e.g.
children).
- exception_retry_count (int): How many times to retry by
transaction rollback on exception. This could happen in a race condition if another worker is trying to create the same task. The default is to retry twice.
- status (str): Task status. See