* New dequeue strategy This implements a new parameter `dequeue_strategy` that should replace the `RoundRobinWorker` and `RandomWorker`. Changes includes: feature, docs, tests, deprecation warning. * Fix dequeue strategy name * Black & Fix warning * feat: tests, warnings, refactor naming * feat: improve worker check * fix: revert to str subclass * fix: dequeue strategy into bootstrap * org: move DequeueStrategy to worker * refactor: round robin naming * fix: naming * fix: type annotation * fix: typo * refactor: remove kwarg from worker's init * fix: typo * move `dequeue_strategy` from `bootstrap()` into `work()`
* fix accessing None when dequeued result is None (burst=True, or timeout=None) * add a test * implement + tests * fix if * adjust test * merge * test * test * merge master * take max_idle_time into account for dequeue_timeout * refactor a bit * potential bug fix * tests * math.ceil * buffer tests
* Configurable maintenance task interval * pass to worker * rename parameter * rename * rename * test
* enhance worker termination logic and allow passing custom exc_info in failure callback * handle ret_val None * fix unbound variable * typing * docs * Update exceptions.md * rename * typing * rename * Update exceptions.md * revert test change
* Use worker TTL for timeout * add test * renames * test * use dequeue_timeout
* fix accessing None when dequeued result is None (burst=True, or timeout=None) * add a test * pr fix * fix tests
* Enhanced Redis Connection Reliability The Redis connection may fail for several reasons. As the connection can be (1) explicitly passed to the worker or (2) implicity set, this will improve the Connection configuration by setting a timeout to the socket, and adding an ExponentialBackoff Retry logic. * Simpler Connection logic * Add simple retry logic to Redis Connection Error * Make retry exponential, add keepalive & socket_connect_timeout * Handles configuration on Redis' connection pool * Simplifies timeout exception logic * Fix burst bug, add test * Add docs related to `socket_timeout`, improve compatibility with older RedisPy versions * Fixes * New timeout private method * Fix timeout
* Remove unused code from compat module * Remove unused dictconfig * Remove total_ordering compat layer * Remove compatibility layer This completely removes the compat module. It moves utilities functions (`as_text` and `decode_redis_hash`) to the `utils` module, is eliminates the use of the proxies `text_type` and `string_types`, using the `str` construct directly. * Remove compat module Finishes the cleaning of the compatibility module. The last function being the `is_python_version` function which was being used internally. * Fix old import * Fix Imports * Remove Dummy (Force GH Actions) * Fix Imports * Organize Imports
* Persist worker_name after job is finished Persisting the worker_name on the job object in Redis would allow for debugging and analyzing logs from the worker * Remove redundent job.save() method call * Remove check for null worker Now that worker name is persisted after job finishes or fails, no need to assert that worker name is None * Change github runner to Ubuntu 20.04 * Change github runner to Ubuntu 20.04
* WIP job results * Result can now be saved * Successfully saved and restored result * result.save() should accept pipeline * Successful results are saved * Failures are now saved properly too. * Added test for Result.get_latest() * Checkpoint * Got Result.all() to work * Added Result.count(), Result.delete() * Backward compatibility for job.result and job.exc_info * Added some typing * More typing stuff * Fixed typing in job.py * More typing updates * Only keep the last 10 results * Documented job.results() * Got results test to pass * Don't run test_results.py on Redis server < 5.0 * Fixed mock import on some Python versions * Remove Redis 3 from test matrix * Jobs should never use the new Result implementation if server is < 5.0 * Results should only be created is Redis stream is supported. * Added back Redis 3 to test matrix * Fixed job.supports_redis_streams * Fixed worker test * Updated docs.