- worker: Wait for jobs to finalize on close (#2545) [python] (
d81f210
)
- redis-connection: Increase redis retry strategy backoff (#2546) [python] (
6cf7712
)
- stalled: Consider ignoreDependencyOnFailure option (python) (#2540) fixes #2531 (
0140959
)
- stalled: Consider failParentOnFailure when moving child into failed (#2526) fixes #2464 (python) (
5e31eb0
)
- queue: Add getJobLogs method [python] (#2523) ref #2472 (
a24a16e
)
- worker: Use 0.002 as minimum timeout for redis version lower than 7.0.8 [python] (#2521) (
f3862dd
) - Allow arbitrary large drainDelay (
9693321
)
- worker: Use 0.002 as minimum timeout for redis version lower than 7.0.8 (#2515) fixes #2466 (
44f7d21
)
- python: Support reusable redis connections (
29ad8c8
)
- stalled: Remove jobId from stalled after removing lock when moved from active (#2512) (python) (
64feec9
)
- worker: Set blockTimeout as 0.001 when reach the time to get delayed jobs [python] (#2478) (
b385034
)
- job: Add log method [python] (#2476) ref #2472 (
34946c4
)
- marker: Differentiate standard and delayed markers (python) (#2389) (
18ebee8
) - change-delay: Add delay marker when needed (#2411) (
8b62d28
)
- reprocess-job: Add marker if needed (#2406) (
5923ed8
) - rate-limit: Move job to wait even if ttl is 0 (#2403) (
c1c2ccc
) - stalled: Consider adding marker when moving job back to wait (#2384) (
4914df8
)
- flow: Add marker when moving parent to wait (python) (#2408) (
6fb6896
) - move-to-active: Check rate limited once (#2391) (
ca6c17a
)
- redis: Upgrade to v5 [python] (#2364) (
d5113c8
) - worker: Worker can be closed if Redis is down (#2350) (
888dcc2
)
- job: Add isActive method [python] (#2352) (
afb5e31
) - job: separate attemptsMade from attemptsStarted when manually moving a job (#2203) (
0e88e4f
) - scripts: Use new queue markers (
4276eb7
) - worker: Improved markers handling (
73cf5fc
) (0bac0fb
)
- Markers use now a dedicated key in redis instead of using a special Job ID. (
73cf5fc
) (0bac0fb
) - Connection must be provided as part of options (#2282) (
8eee20f
)
- retry: Pass right redis command name into retryJob script (#2321) [python] (
6bb21a0
) - flows: Add meta key to queues created with flows (
272ec69
) - update-progress: Remove old updateProgress script to prevent conflict (#2298) (python) (
e65b819
) - worker: Should cap update progress events (
2cab9e9
)
- worker: Do not wait for slow jobs fixes #2290 (
568d758
)
- job: Set delay value on current job instance when it is retried (#2266) (python) (
76e075f
)
- backoff: Fix builtin backoff type (#2265) [python] (
76959eb
)
- add-job: Trim events when waiting-children event is published (#2262) (python) (
198bf05
)
- events: Do not publish removed event on non-existent jobs (#2227) (
c134606
) - events: Trim events when retrying a job (#2224) (
1986b05
)
- events: Trim events when removing jobs (#2235) (python) (
889815c
)
- Nothing change
- move-to-finished: Stringify any return value [python] (#2198) fixes #2196 (
07f1335
) - queue: Batched unpack now uses range (#2188) (
b5e97f4
) - queue: Differentiate score purpose per state in clean method (#2133) fixes #2124 (
862f10b
)
- move-to-finished: Consider addition of prioritized jobs when processing last active job (#2176) (python) (
4b01f35
)
- worker: Respect concurrency (#2062) fixes #2063 (
1b95185
)
- pyproject: Add requires-python config (#2056) fixes #1979 (
a557970
)
- pyproject: Build egg-info at the root location (
3c2d06e
)
- queue: Add getFailedCount method (#2036) (
92d7227
) - queue: Add getCompletedCount method (#2033) (
3e9db5e
)
- priority is separeted in its own zset, no duplication needed (
42a890a
)
- priority: Add prioritized as a new state (#1984) (python) (
42a890a
)
- rate-limit: Keep priority fifo order (#1991) fixes #1929 (python) (
56bd7ad
) - worker: Set redis version always in initialization (#1989) fixes #1988 (
a1544a8
)
- python: Include lua scripts when releasing (
bb4f3b2
)
- deps: Downgrade python-semantic-release to avoid version issue
v0.4.0 (2023-05-18)
- connection: accept redis options as string (
01f549e
) - job: add moveToDelayed job method (#1849) (
5bebf8d
) - job: Add retry method into job (#1877) (
870da45
) - job: Add updateData method (#1871) (
800b8c4
) - job: Add updateProgress method in job class(#1830) (
e1e1aa2
) - job: Save stacktrace when job fails (#1859) (
0b538ce
) - Support retryJob logic (#1869) (
b044a03
)
- retry: Consider when queue is paused (#1880) (
01b621f
) - worker: Stop processes when force stop (#1837) (
514699c
)
v0.3.0 (2023-04-18)
- Correct condition so that the worker keeps processing jobs indefinitely (#1800) (
ef0c5d6
) - Fix scripts typing on array2obj function (#1786) (
134f6ab
) - Pass maxMetricsSize as empty string when it is not provided fixes (#1754) (
6bda2b2
)
v0.2.0 (2023-03-29)
- Initial python package (
a97b22f
)