Changelog
Last updated
Was this helpful?
Last updated
Was this helpful?
flow: Support failed children in getFlow and getDependencies methods () ()
flow: Support ignored children in getFlow and getDependencies methods (#3238) ref #3213 ()
queue: Add getIgnoredChildrenFailures method () ()
job: Expose stalledCounter attribute () ()
Add removeUnprocessedChildren () ()
flows: Add continueParentOnFailure option () ()
updateProgress: Allow more types to be used as progress () ()
Add deduplicated job id to the deduplicated event ()
prometheus export: Expose global variables ()
connection: Add str type in connection option [python] () ()
queue-events: Omit telemetry options () ()
job-scheduler: Remove next delayed job if present even if scheduler does not exist (#3203) ref #3197 ()
deduplication: Remove deduplication key only when jobId matches with the last one being saved () ()
flow-producer: Use FlowProducer prefix by defualt when calling getFlow () ()
Made line split more compatible () ()
job-scheduler: Fix endDate presence validation () ()
flow: Remove job from dependencies when failParentOnFailure or continueParentOnFailure () ()
flow-producer: Fix queueName otel attribute when passing it to addNode () ()
queue-events: Pass right path for JobProgress type (#3192) fixes #3191 ()
flow: Validate pending dependencies before removing lock () ()
job-scheduler: Emit duplicated event when next delayed job exists () ()
scheduler: Remove next delayed job when possible () ()
flow: Only validate pending dependencies when moving to completed () ()
flow: Consider prioritized state when moving a parent to failed () ()
Nothing change
deps: Downgrade python-semantic-release to avoid version issue
readme: Fix typo for Job.fromId text () ()
aws-elasticache: Fix typo () ()
flow: Change parent failure in a lazy way () ()
flow: Validate parentKey existence before trying to move it to failed () ()
job-scheduler: Add marker when upserting job scheduler if needed () ()
job: Support ignored and failed counts in getDependenciesCount (#3137) ref #3136 ()
job: Add complete span in moveToCompleted method () ()
job-scheduler: Restore iterationCount attribute () ()
flow: Consider to fail a parent not in waiting-children when failParentOnFailure is provided () ()
scheduler: Remove multi when updating a job scheduler () ()
job: Deserialize priority in fromJSON () ()
nestjs-bullmq-pro: Update changelog to v3.1.0 () ()
worker: Optimize job retrieval for failed jobs in chunks () ()
worker: Cast delay_until to integer [python] () ()
flow: Consider delayed state when moving a parent to failed () ()
Replace multi by lua scripts in moveToFailed () ()
job: Set processedBy when moving job to active in moveToFinished (#3077) fixes #3073 ()
drain: Pass delayed key for redis cluster () ()
retry-job: Consider updating failures in job () ()
dynamic-rate-limit: Validate job lock cases () ()
scripts: Make sure jobs fields are not empty before unpack ()
flow: Allow using removeOnFail and failParentOnFailure in parents (#2947) fixes #2229 ()
delayed: Add marker once when promoting delayed jobs (#3096) (python) ()
add-job: Add job into wait or prioritized state when delay is provided as 0 () ()
queue: Add getDelayedCount method [python] () ()
marker: Add base markers while consuming jobs to get workers busy (#2904) fixes #2842 ()
commands: Add missing build statement when releasing [python] (#2869) fixes #2868 ()
job: Add getChildrenValues method [python] () ()
queue: Add option to skip metas update ()
queue: Add queue version support () ()
job: Expose priority value () ()
job: Add deduplication logic () ()
queue: Add getDebounceJobId method () ()
Proper way to get version ()
redis: Use version for naming loaded lua scripts ()
metrics: Differentiate points in different minutes to be more accurate (#2766) (python) ()
metrics: Save zeros as much as max data points () ()
flows: Throw error when queueName contains colon (#2719) fixes #2718 ()
flow: Remove debounce key when parent is moved to fail () ()
flow: Recursive ignoreDependencyOnFailure option () ()
job: Throw error if removeDependencyOnFailure and ignoreDependencyOnFailure are used together () ()
stalled: Support removeDependencyOnFailure option when job is stalled () ()
job: Change moveToFinished return type to reflect jobData (#2706) ref #2342 ()
connection: Remove unnecessary process.env.CI reference () ()
worker: Fix close sequence to reduce risk for open handlers () ()
flow: Validate parentData before ignoreDependencyOnFailure when stalled check happens (#2702) (python) ()
worker: Promote delayed jobs while queue is rate limited (#2697) ref #2582 ()
job: Consider passing stackTraceLimit as 0 (#2692) ref #2487 ()
queue-events: Pass debounceId as a param of debounced event () ()
job: Allow passing a debounce as option () ()
repeatable: New repeatables structure (#2617) ref #2612 fixes #2399 #2596 ()
queue: Support global concurrency (#2496) ref #2465 ()
job: Make sure json.dumps return JSON compliant JSON [python] () ()
repeatable: Remove repeat hash when removing repeatable job () ()
repeatable: Keep legacy repeatables if it exists instead of creating one with new structure () ()
repeatable: Consider removing legacy repeatable job (#2658) fixes #2661 ()
repeatable: Pass custom key as an args in addRepeatableJob to prevent CROSSSLOT issue (#2662) fixes #2660 ()
worker: Fetch next job on failure () ()
delayed: Avoid using jobId in order to schedule delayed jobs (#2587) (python) ()
delayed: Keep moving delayed jobs to waiting when queue is paused (#2640) (python) ()
queue: Add getCountsPerPriority method [python] () ()
parent: Consider re-adding child that is in completed state using same jobIds (#2627) (python) fixes #2554 ()
priority: Consider paused state when calling getCountsPerPriority (python) () ()
priority: Use module instead of bit.band to keep order (python) () ()
Remove print calls [python] () ()
retry-job: Throw error when job is not in active state () ()
job: Validate job existence when adding a log () ()
job: Set processedBy using hmset (#2592) (python) ()
connection: Use async Retry (#2555) [python] ()
worker: Make sure clearTimeout is always called after bzpopmin ()
worker: Force timeout on bzpopmin command () ()
worker: Wait for jobs to finalize on close (#2545) [python] ()
redis-connection: Increase redis retry strategy backoff (#2546) [python] ()
stalled: Consider ignoreDependencyOnFailure option (python) (#2540) fixes #2531 ()
worker: Return minimumBlockTimeout depending on redis version (python) () ()
stalled: Consider failParentOnFailure when moving child into failed (#2526) fixes #2464 (python) ()
queue: Add getJobLogs method [python] (#2523) ref #2472 ()
worker: Use 0.002 as minimum timeout for redis version lower than 7.0.8 [python] () ()
Allow arbitrary large drainDelay ()
worker: Use 0.002 as minimum timeout for redis version lower than 7.0.8 (#2515) fixes #2466 ()
python: Support reusable redis connections ()
stalled: Remove jobId from stalled after removing lock when moved from active (#2512) (python) ()
connection: Accept all parameters for redis connection [python] () ()
scripts: Use command name in error message when moving to finished () ()
worker: Set blockTimeout as 0.001 when reach the time to get delayed jobs [python] () ()
job: Add log method [python] (#2476) ref #2472 ()
flow: Parent job cannot be replaced (python) () ()
marker: Differentiate standard and delayed markers (python) () ()
change-delay: Add delay marker when needed () ()
reprocess-job: Add marker if needed () ()
rate-limit: Move job to wait even if ttl is 0 () ()
stalled: Consider adding marker when moving job back to wait () ()
flow: Add marker when moving parent to wait (python) () ()
move-to-active: Check rate limited once () ()
retry-jobs: Add marker when needed () ()
queue: Add promoteJobs method [python] () ()
repeatable: Allow saving custom key () ()
redis: Upgrade to v5 [python] () ()
worker: Worker can be closed if Redis is down () ()
job: Add isActive method [python] () ()
job: separate attemptsMade from attemptsStarted when manually moving a job () ()
scripts: Use new queue markers ()
worker: Improved markers handling () ()
connection: Unify redis connection args for Queue and Worker () ()
Markers use now a dedicated key in redis instead of using a special Job ID. () ()
Connection must be provided as part of options () ()
job: Add isWaitingChildren method [python] () ()
queue: Add getRateLimitTtl method [python] () ()
job: Add isFailed method [python] () ()
job: Add isCompleted method [python] () ()
job: Add isWaiting method [python] () ()
job: Add promote method [python] () ()
retry: Pass right redis command name into retryJob script (#2321) [python] ()
flows: Add meta key to queues created with flows ()
update-progress: Remove old updateProgress script to prevent conflict (#2298) (python) ()
worker: Should cap update progress events ()
worker: Better handling of concurrency when fetching jobs () ()
worker: Do not wait for slow jobs fixes #2290 ()
job: Set delay value on current job instance when it is retried (#2266) (python) ()
backoff: Fix builtin backoff type (#2265) [python] ()
Update delay job property when moving to delayed set () ()
add-job: Trim events when waiting-children event is published (#2262) (python) ()
events: Do not publish removed event on non-existent jobs () ()
events: Trim events when retrying a job () ()
events: Trim events when removing jobs (#2235) (python) ()
delayed: Trim events when moving jobs to delayed (python) () ()
queue: Add clean method [python] () ()
move-to-finished: Stringify any return value [python] (#2198) fixes #2196 ()
queue: Batched unpack now uses range () ()
queue: Differentiate score purpose per state in clean method (#2133) fixes #2124 ()
remove: Change error message when job is locked (python) () ()
move-to-finished: Consider addition of prioritized jobs when processing last active job (#2176) (python) ()
flow-producer: Add addBulk method (python) () ()
queue: Add addBulk method () ()
Add flow producer class () ()
job: Job getReturnValue not returning returnvalue () ()
rate-limit: Get pttl only if needed () ()
redis-connection: Add username option into redisOpts () ()
retry: Compare prev state instead of regex expression () ()
job: Add option for removing children in remove method (python) () ()
worker: Respect concurrency (#2062) fixes #2063 ()
queue: Add remove method () ()
worker: Add id as part of token () ()
pyproject: Add requires-python config (#2056) fixes #1979 ()
job: Add moveToWaitingChildren method () ()
queue: Fix isPaused method when custom prefix is present () ()
queue: Add getJobState method () ()
pyproject: Build egg-info at the root location ()
queue: Add getFailedCount method () ()
queue: Add getCompletedCount method () ()
release: Add recommended pyproject.toml configuration () ()
queue: Add get job methods by state () ()
queue: Add getJobs method () ()
priority is separeted in its own zset, no duplication needed ()
priority: Add prioritized as a new state (#1984) (python) ()
queue: Pass right params to trimEvents method () ()
rate-limit: Keep priority fifo order (#1991) fixes #1929 (python) ()
worker: Set redis version always in initialization (#1989) fixes #1988 ()
connection: Add retry strategy in connection () ()
worker: Use timeout as integer for redis lower than v6.0.0 (python) () ()
retry-job: Consider priority when moving job to wait (python) () ()
python: Include lua scripts when releasing ()
python: Add remove job method () ()
Add changePriority method () ()
rate-limit: Consider paused queue () ()
deps: Fix 'install_requires' to include semver () ()
job: Add getState method () ()
connection: accept redis options as string ()
job: add moveToDelayed job method () ()
job: Add retry method into job () ()
job: Add updateData method () ()
job: Add updateProgress method in job class() ()
job: Save stacktrace when job fails () ()
Support retryJob logic () ()
retry: Consider when queue is paused () ()
worker: Stop processes when force stop () ()
queue: Add getJobCounts method () ()
Improve worker concurrency () ()
Correct condition so that the worker keeps processing jobs indefinitely () ()
Fix scripts typing on array2obj function () ()
Pass maxMetricsSize as empty string when it is not provided fixes () ()
Add trimEvents method () ()
queue: Add retryJobs method () ()
Initial python package ()