Tags: codingXiang/machinery
Tags
feat: update redis libraries to new versions (RichardKnop#584)
Revert "ensure consuming blocked by previous task (RichardKnop#559) (R… …ichardKnop#580)" (RichardKnop#583) This reverts commit 706f08b.
Update deps (RichardKnop#576) * update dependencies, don't reload env based config * update README * fix unit test
Use UNWATCH when MULTI is not called (RichardKnop#568) * use unwatch when mutli is not called * add comment
Fix 413 - (Redis) Simplify TTL (RichardKnop#557) Set TTL for the key at the same time when setting the value
Fix RichardKnop#529 - Set Redis default concurrency when value is 0 (R… …ichardKnop#553) According to the README: > Use the second parameter of `server.NewWorker` to limit the number of concurrently running > worker.Process() calls (per worker). Example: 1 will serialize task execution while 0 makes > the number of concurrently executed tasks unlimited (default). This change will set the concurrency to 2 * num CPUs when concurrency = 0. While it isn't "unlimited", it is neverthe a practical choice for most workloads (mixed CPU, I/O) and better than 1. This change should make the behavior more consistent with the doc. Should also fix RichardKnop#535 Co-authored-by: Charles Chan <charles.wh.chan@users.noreply.github.com> Co-authored-by: Richard Knop <RichardKnop@users.noreply.github.com>
Fix RichardKnop#548 - Use math.Ceil(pollPeriod) to ensure BLPOP timeo… …ut is an integer (RichardKnop#554) Co-authored-by: Charles Chan <charles.wh.chan@users.noreply.github.com>
[Redis Broker] Wait for currently processing tasks to finish before c… …losing the redis pool (RichardKnop#552)
PreviousNext