I am adding a new extractor plugin where the service will be asynchronous. So the first time I will create a job with the service and then I want to check this again in the next cron run. We already have 'DelayedRequeueException' → where we can use this to delay the current item in queue for a specific time or till next cron run. But in the current QueueWorker plugin, all exceptions are being caught and retried for 5 times (which will happen without delay).
-
In QueueWorker plugin, check if the exception is of type 'DelayedRequeueException'. If so, we throw it and if not we retry as cuttenyly does.
Test and create patch as explained above.
-
-
-
Needs review
9.0
Code
I have tried this for my case and it works as expected. When we throw 'DelayedRequeueException' it will be handled by core cron and in case of other exceptions we do the same re-attempt logic.