tags:

views:

6

answers:

0

I have a worker with concurrency set to 1 and a task that goes into infinite loop [for testing]. I submit a task T1 and the worker gets it and goes to work. I submit another task, it gets it and since its busy with T1 still, T2 goes into Queue [rabbitMQ].

I tried T2.revoke() and revoke(t2.task_id)

And checked with the inspect to see the revoked status. Every thing looks good. But when i restart the worker, it still executes T2.

Is there any thing that needs to be done to suppress the T2 from execution ?