diff --git a/django_q/tasks.py b/django_q/tasks.py index a6694e16..15914e51 100644 --- a/django_q/tasks.py +++ b/django_q/tasks.py @@ -32,6 +32,7 @@ def async_task(func, *args, **kwargs): "chain", "broker", "timeout", + "retry", ) q_options = keywords.pop("q_options", {}) # get an id diff --git a/docs/tasks.rst b/docs/tasks.rst index d631cdc6..c4ebf88b 100644 --- a/docs/tasks.rst +++ b/docs/tasks.rst @@ -59,6 +59,13 @@ Overrides the cluster's timeout setting for this task. See :ref:`retry` for details how to set values for timeout. +retry +""""" +Adds custom `retry` value for this task. + +Note that you have to implement your custom broker in order +to override the cluster's retry setting by using this value. + ack_failure """"""""""" Overrides the cluster's :ref:`ack_failures` setting for this task.