Skip to content

v0.7.3

Compare
Choose a tag to compare
@Koed00 Koed00 released this 18 Sep 17:54
· 694 commits to master since this release
  • 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.