The current worker implementation does not update the DB entry in the case of errors (and stops processing all messages when the first error is encountered).
Things should not be this way. We should generically try/except so that job status is always updated and job processing continues to the next job as appropriate.
The current worker implementation does not update the DB entry in the case of errors (and stops processing all messages when the first error is encountered).
Things should not be this way. We should generically try/except so that job status is always updated and job processing continues to the next job as appropriate.
Propagation should also include an error message.