dramatiq
dramatiq copied to clipboard
send_with_options with delay seems not right
Issues
GitHub issues are for bugs. If you have questions, please ask them on the discussion board.
Checklist
- [ ] Does your title concisely summarize the problem?
- [ ] Did you include a minimal, reproducible example?
- [ ] What OS are you using?
- [ ] What version of Dramatiq are you using?
- [ ] What did you do?
- [ ] What did you expect would happen?
- [ ] What happened?
What OS are you using?
centos
What version of Dramatiq are you using?
1.10.0
What did you do?
@task_queue.actor
def execute_job(job_id):
res = xxxx()
if not res:
execute_job.send_with_options(args=(1951936, ), delay=10000) # retry after 10 seconds
What did you expect would happen?
I wish execute_job would run after 10 seconds but is seems random