8.1.5. TaskQueue¶

Implement a Task Queue using an asyncio event loop and queue.

class sidita.TaskQueue.Consumer(worker_id, task_queue, worker_main=PosixPath('/home/fabrice/home/developpement/python/sidita/sidita/worker.py'), python_path=None, worker_module='sidita.Worker', worker_cls='Worker', max_memory=0, memory_check_interval=datetime.timedelta(0, 60), task_timeout=None)[source]¶

Bases: object

DEFAULT_WORKER_CLASS = 'Worker'¶

DEFAULT_WORKER_MAIN = PosixPath('/home/fabrice/home/developpement/python/sidita/sidita/worker.py')¶

DEFAULT_WORKER_MODULE = 'sidita.Worker'¶

dead¶

id¶

metrics¶

run()[source]¶

class sidita.TaskQueue.TaskQueue(number_of_workers=None, max_queue_size=0, **kwargs)[source]¶

Bases: object

get_task()[source]¶

on_result(task_metadata)[source]¶

on_stream_error(task_metadata)[source]¶

on_task_sent(task_metadata)[source]¶

on_task_submitted(task_metadata)[source]¶

on_timeout_error(task_metadata)[source]¶

run()[source]¶

send_stop()[source]¶

submit(task)[source]¶

task_producer()[source]¶