search

komuw / wiji

Wiji is an asyncio distributed task processor/queue.
MIT License
4 stars 1 forks source link

broker should have a function called every X seconds #59

Closed komuw closed 5 years ago

komuw commented 5 years ago

see; https://github.com/komuw/wijisqs/issues/36 for a possible justification

komuw commented 5 years ago

No longer needed,

wiji.worker.Worker already calls broker.dequeue in a while loop; https://github.com/komuw/wiji/blob/65ca5d8c5cc39970fbe3a7e4cd73963c6fc067f7/wiji/worker.py#L267-L271 Any broker that needs to run this on a schedule should implement it inside the broker.dequeue method.

WijiSqs has done so: https://github.com/komuw/wijisqs/pull/46