MemoryTaskQueue

A simple Task Queue with a retry mechanism.

Example

from memory_task_queue import MemoryTaskQueue

def my_callback(item):
    print(item)

def my_fallback(item):
    print('Callback failed to run')

mtq = MemoryTaskQueue(my_callback, on_max_retries=my_fallback, delay=0.3, max_retries=3)

mtq.put({'message': 'hello world'})