- adds
wait
parameter to result
and fetch
methods which will make them wait n milliseconds for a result to appear.
from django_q import async, result, fetch
# queue a task
task_id = async('math.copysign', 1, -1)
# wait 200 milliseconds for a result
result = result(task_id, 200)
# or wait 500 milliseconds for a result object
task = fetch(task_id, 500)
- adds support for
lock_size
to the broker class which counts the number of tasks currently locked for acknowledgement.
- brokers that support a lock/reservation count will show this in the monitor.
Queued 1988(24)
with the bracketed number being the amount of tasks awaiting acknowledgment.
- adds lock size to the SQS broker. Note that due to the nature of SQS, this is not atomic but rather an approximation.