#137 addresses purging tasks in an error state. But long running periodic tasks can have an ever increasing list of execution errors that will never get purged. A function should be provided that can be used to trim the execution list for periodic tasks so that they don't have unbounded growth.
Another idea would be to have a max executions config setting and do a LTRIM every time we add to the execution list here:
|
self.connection.rpush( |
|
self._key('task', task.id, 'executions'), |
|
serialized_execution, |
|
) |
#137 addresses purging tasks in an error state. But long running periodic tasks can have an ever increasing list of execution errors that will never get purged. A function should be provided that can be used to trim the execution list for periodic tasks so that they don't have unbounded growth.
Another idea would be to have a max executions config setting and do a
LTRIMevery time we add to the execution list here:tasktiger/tasktiger/worker.py
Lines 409 to 412 in fe82e84