Eric Allam
bf43fd4f8e
* Improve the MarQS priority system by moving future messages into the LRE worker and using a priority timestamp offset to define priority in messages * Add a test to make sure priority offsets don't unfairly favor environments * requeuing should clear concurrency sets * Heartbeats should only reschedule existing heartbeat jobs * Fix type error
Redis worker
This is a simple worker that pulls tasks from a Redis queue (also in this package).
Features
- Configurable settings for concurrency and pull speed.
- Job payloads.
- A schema so only defined jobs can be added to the queue.
- The ability to have future dates for jobs.