The task of recalling celery with SQS

Question

I am using Celery + Kombu with Amazon SQL. The goal is to remove the task already scheduled for a specific datetime. I tried

from celery.task.control import revoke revoke(task_id) 

but that didn’t change anything. Is SQS denial of transportation canceled? Is there some kind of design decision or just a missing feature that needs to be implemented by some kind of DeleteMessage line of code?

Answer 1

If you are not using RabbitMQ, it is better to come up with a special solution for recalling tasks. For instance. Instead of completing tasks, create a system of two components: a task scheduler that scans your table of potential tasks and performs them if necessary. No need to cancel, you just can decide not to complete the task when necessary.