django_celery_results.backends.database

class django_celery_results.backends.database.DatabaseBackend(app, serializer=None, max_cached_results=None, accept=None, expires=None, expires_type=None, url=None, **kwargs)[source]

The Django database backend, using models to store task state.

GroupModel

alias of django_celery_results.models.GroupResult

TaskModel

alias of django_celery_results.models.TaskResult

apply_chord(header_result_args, body, **kwargs)[source]

Add a ChordCounter with the expected number of results

cleanup()[source]

Delete expired metadata.

decode_content(obj, content)[source]
encode_content(data)[source]
on_chord_part_return(request, state, result, **kwargs)[source]

Called on finishing each part of a Chord header

subpolling_interval = 0.5

Time to sleep between polling each individual item in ResultSet.iterate. as opposed to the interval argument which is for each pass.

django_celery_results.backends.database.trigger_callback(app, callback, group_result)[source]

Add the callback to the queue or mark the callback as failed Implementation borrowed from celery.app.builtins.unlock_chord