Managers - djcelery.managers
-
class djcelery.managers.ExtendedManager
-
connection_for_read()
-
connection_for_write()
-
current_engine()
-
get_query_set()
-
get_queryset()
-
update_or_create(**kwargs)
-
class djcelery.managers.ExtendedQuerySet(model=None, query=None, using=None)
-
update_or_create(**kwargs)
-
class djcelery.managers.PeriodicTaskManager
-
enabled()
-
class djcelery.managers.ResultManager
-
delete_expired(expires)
Delete all expired taskset results.
-
get_all_expired(expires)
Get all expired task results.
-
class djcelery.managers.TaskManager
Manager for celery.models.Task models.
-
get_task(task_id)
Get task meta for task by task_id.
Parameters: | exception_retry_count – How many times to retry by
transaction rollback on exception. This could theoretically
happen in a race condition if another worker is trying to
create the same task. The default is to retry once. |
-
store_result(*args, **kwargs)
Store the result and status of a task.
Parameters: |
- task_id – task id
- result – The return value of the task, or an exception
instance raised by the task.
- status – Task status. See
celery.result.AsyncResult.get_status() for a list of
possible status values.
- traceback – The traceback at the point of exception (if the
task failed).
- children – List of serialized results of subtasks
of this task.
- exception_retry_count – How many times to retry by
transaction rollback on exception. This could theoretically
happen in a race condition if another worker is trying to
create the same task. The default is to retry twice.
|
-
warn_if_repeatable_read()
-
class djcelery.managers.TaskSetManager
Manager for celery.models.TaskSet models.
-
delete_taskset(taskset_id)
Delete a saved taskset result.
-
restore_taskset(taskset_id)
Get the async result instance by taskset id.
-
store_result(*args, **kwargs)
Store the async result instance of a taskset.
Parameters: |
- taskset_id – task set id
- result – The return value of the taskset
|
-
class djcelery.managers.TaskStateManager
-
active()
-
expire_by_states(states, expires)
-
expired(states, expires, nowfun=<function now at 0x7fcfbbe499b0>)
-
purge()
-
exception djcelery.managers.TxIsolationWarning
-
djcelery.managers.transaction_retry(max_retries=1)
Decorator for methods doing database operations.
If the database operation fails, it will retry the operation
at most max_retries times.
-
djcelery.managers.update_model_with_dict(obj, fields)