BullMQ
  • What is BullMQ
  • Quick Start
  • API Reference
  • Changelogs
    • v4
    • v3
    • v2
    • v1
  • Guide
    • Introduction
    • Connections
    • Queues
      • Auto-removal of jobs
      • Adding jobs in bulk
      • Global Concurrency
      • Removing Jobs
    • Workers
      • Auto-removal of jobs
      • Concurrency
      • Graceful shutdown
      • Stalled Jobs
      • Sandboxed processors
      • Pausing queues
    • Jobs
      • FIFO
      • LIFO
      • Job Ids
      • Job Data
      • Deduplication
      • Delayed
      • Repeatable
      • Prioritized
      • Removing jobs
      • Stalled
      • Getters
    • Job Schedulers
      • Repeat Strategies
      • Repeat options
      • Manage Job Schedulers
    • Flows
      • Adding flows in bulk
      • Get Flow Tree
      • Fail Parent
      • Continue Parent
      • Remove Dependency
      • Ignore Dependency
      • Remove Child Dependency
    • Metrics
      • Prometheus
    • Rate limiting
    • Parallelism and Concurrency
    • Retrying failing jobs
    • Returning job data
    • Events
      • Create Custom Events
    • Telemetry
      • Getting started
      • Running Jaeger
      • Running a simple example
    • QueueScheduler
    • Redisâ„¢ Compatibility
      • Dragonfly
    • Redisâ„¢ hosting
      • AWS MemoryDB
      • AWS Elasticache
    • Architecture
    • NestJs
      • Producers
      • Queue Events Listeners
    • Going to production
    • Migration to newer versions
    • Troubleshooting
  • Patterns
    • Adding jobs in bulk across different queues
    • Manually processing jobs
    • Named Processor
    • Flows
    • Idempotent jobs
    • Throttle jobs
    • Process Step Jobs
    • Failing fast when Redis is down
    • Stop retrying jobs
    • Timeout jobs
    • Timeout for Sandboxed processors
    • Redis Cluster
  • BullMQ Pro
    • Introduction
    • Install
    • Observables
      • Cancelation
    • Groups
      • Getters
      • Rate limiting
      • Local group rate limit
      • Concurrency
      • Local group concurrency
      • Max group size
      • Pausing groups
      • Prioritized intra-groups
      • Sandboxes for groups
    • Telemetry
    • Batches
    • NestJs
      • Producers
      • Queue Events Listeners
      • API Reference
      • Changelog
    • API Reference
    • Changelog
    • New Releases
    • Support
  • Bull
    • Introduction
    • Install
    • Quick Guide
    • Important Notes
    • Reference
    • Patterns
      • Persistent connections
      • Message queue
      • Returning Job Completions
      • Reusing Redis Connections
      • Redis cluster
      • Custom backoff strategy
      • Debugging
      • Manually fetching jobs
  • Python
    • Introduction
    • Changelog
Powered by GitBook

Copyright (c) Taskforce.sh Inc.

On this page
  • v2.15.0 (2025-05-13)
  • Feature
  • Fix
  • Documentation
  • v2.14.0 (2025-05-01)
  • Feature
  • Fix
  • Documentation
  • Performance
  • v2.13.1 (2025-03-15)
  • Fix
  • v2.13.0 (2025-03-15)
  • Feature
  • Fix
  • Documentation
  • Performance
  • v2.12.1 (2025-02-28)
  • Fix
  • v2.12.0 (2025-02-21)
  • Feature
  • Fix
  • Performance
  • v2.11.0 (2024-11-26)
  • Feature
  • Performance
  • v2.10.1 (2024-10-26)
  • Fix
  • v2.10.0 (2024-10-24)
  • Feature
  • Fix
  • v2.9.4 (2024-09-10)
  • Fix
  • Performance
  • v2.9.3 (2024-08-31)
  • Fix
  • v2.9.2 (2024-08-10)
  • Fix
  • Performance
  • v2.9.1 (2024-08-08)
  • Fix
  • v2.9.0 (2024-08-02)
  • Feature
  • Fix
  • Performance
  • v2.8.1 (2024-07-11)
  • Fix
  • Performance
  • v2.8.0 (2024-07-10)
  • Feature
  • Fix
  • v2.7.8 (2024-06-05)
  • Fix
  • v2.7.7 (2024-06-04)
  • Fix
  • Performance
  • v2.7.6 (2024-05-09)
  • Fix
  • v2.7.5 (2024-04-28)
  • Fix
  • v2.7.4 (2024-04-26)
  • Fix
  • v2.7.3 (2024-04-24)
  • Fix
  • v2.7.2 (2024-04-20)
  • Fix
  • v2.7.1 (2024-04-18)
  • Fix
  • v2.7.0 (2024-04-13)
  • Feature
  • v2.6.0 (2024-04-13)
  • Feature
  • Fix
  • v2.5.0 (2024-04-08)
  • Feature
  • v2.4.0 (2024-04-07)
  • Performance
  • v2.3.3 (2024-03-24)
  • Fix
  • v2.3.2 (2024-03-23)
  • Fix
  • v2.3.1 (2024-03-19)
  • Fix
  • v2.3.0 (2024-03-16)
  • Feature
  • v2.2.4 (2024-02-13)
  • Fix
  • v2.2.3 (2024-02-10)
  • Performance
  • v2.2.2 (2024-02-03)
  • Fix
  • Performance
  • v2.2.1 (2024-01-16)
  • Fix
  • v2.2.0 (2024-01-14)
  • Feature
  • v2.1.0 (2024-01-12)
  • Feature
  • Fix
  • v2.0.0 (2023-12-23)
  • Feature
  • Fix
  • Breaking
  • v1.24.0 (2023-12-21)
  • Feature
  • v1.23.0 (2023-12-18)
  • Feature
  • v1.22.0 (2023-12-14)
  • Feature
  • v1.21.0 (2023-12-14)
  • Feature
  • v1.20.0 (2023-12-13)
  • Feature
  • v1.19.0 (2023-12-12)
  • Feature
  • v1.18.0 (2023-12-10)
  • Fix
  • v1.17.0 (2023-11-24)
  • Feature
  • Fix
  • v1.16.1 (2023-11-09)
  • Fix
  • v1.16.0 (2023-11-08)
  • Fix
  • v1.15.4 (2023-11-05)
  • Fix
  • v1.15.3 (2023-11-05)
  • Fix
  • v1.15.2 (2023-10-18)
  • Fix
  • Performance
  • v1.15.1 (2023-10-04)
  • Fix
  • v1.15.0 (2023-09-30)
  • Feature
  • v1.14.0 (2023-09-26)
  • Feature
  • Fix
  • v1.13.2 (2023-09-12)
  • Fix
  • v1.13.1 (2023-09-11)
  • Fix
  • v1.13.0 (2023-09-07)
  • Feature
  • v1.12.0 (2023-08-31)
  • Feature
  • v1.11.0 (2023-08-26)
  • Feature
  • v1.10.1 (2023-08-19)
  • Fix
  • Performance
  • v1.10.0 (2023-08-03)
  • Feature
  • Performance
  • v1.9.0 (2023-07-18)
  • Feature
  • v1.8.0 (2023-07-17)
  • Fix
  • v1.7.0 (2023-07-14)
  • Feature
  • v1.6.1 (2023-07-10)
  • Fix
  • v1.6.0 (2023-07-06)
  • Feature
  • v1.5.0 (2023-07-04)
  • Fix
  • v1.4.0 (2023-06-30)
  • Feature
  • v1.3.1 (2023-06-29)
  • Fix
  • v1.3.0 (2023-06-29)
  • Feature
  • Fix
  • v1.2.0 (2023-06-24)
  • Feature
  • v1.1.0 (2023-06-23)
  • Feature
  • v1.0.0 (2023-06-21)
  • Breaking
  • Performance
  • v0.5.6 (2023-06-21)
  • Fix
  • v0.5.5 (2023-06-16)
  • Fix
  • v0.5.4 (2023-06-14)
  • Fix
  • v0.5.3 (2023-06-13)
  • Fix
  • v0.5.2 (2023-06-11)
  • Fix
  • v0.5.1 (2023-06-09)
  • Fix
  • v0.5.0 (2023-06-09)
  • Feature
  • v0.4.4 (2023-06-08)
  • Fix
  • v0.4.3 (2023-06-07)
  • Feature
  • Fix
  • v0.4.2 (2023-06-01)
  • Fix
  • v0.4.1 (2023-05-29)
  • Feature
  • v0.4.0 (2023-05-18)
  • Feature
  • Fix
  • v0.3.0 (2023-04-18)
  • Feature
  • Fix
  • v0.2.0 (2023-03-29)
  • Feature
  • v0.1.0 (2023-02-15)
  • Feature

Was this helpful?

  1. Python

Changelog

PreviousIntroduction

Last updated 15 days ago

Was this helpful?

v2.15.0 (2025-05-13)

Feature

  • job: Add moveToCompleted method [python] () ()

Fix

  • worker: MaxStalledCount no less than 0 (#3249) fixes #3248 ()

  • remove: Pass correct children meta references () ()

Documentation

  • manually-fetching: Fix typo () ()

v2.14.0 (2025-05-01)

Feature

  • 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 ()

Fix

Documentation

Performance

v2.13.1 (2025-03-15)

Fix

v2.13.0 (2025-03-15)

Feature

Fix

Documentation

Performance

v2.12.1 (2025-02-28)

Fix

v2.12.0 (2025-02-21)

Feature

Fix

Performance

v2.11.0 (2024-11-26)

Feature

Performance

v2.10.1 (2024-10-26)

Fix

v2.10.0 (2024-10-24)

Feature

Fix

v2.9.4 (2024-09-10)

Fix

Performance

v2.9.3 (2024-08-31)

Fix

v2.9.2 (2024-08-10)

Fix

Performance

v2.9.1 (2024-08-08)

Fix

v2.9.0 (2024-08-02)

Feature

Fix

Performance

v2.8.1 (2024-07-11)

Fix

Performance

v2.8.0 (2024-07-10)

Feature

Fix

v2.7.8 (2024-06-05)

Fix

v2.7.7 (2024-06-04)

Fix

Performance

v2.7.6 (2024-05-09)

Fix

v2.7.5 (2024-04-28)

Fix

v2.7.4 (2024-04-26)

Fix

v2.7.3 (2024-04-24)

Fix

v2.7.2 (2024-04-20)

Fix

v2.7.1 (2024-04-18)

Fix

v2.7.0 (2024-04-13)

Feature

v2.6.0 (2024-04-13)

Feature

Fix

v2.5.0 (2024-04-08)

Feature

v2.4.0 (2024-04-07)

Performance

v2.3.3 (2024-03-24)

Fix

v2.3.2 (2024-03-23)

Fix

v2.3.1 (2024-03-19)

Fix

v2.3.0 (2024-03-16)

Feature

v2.2.4 (2024-02-13)

Fix

v2.2.3 (2024-02-10)

Performance

v2.2.2 (2024-02-03)

Fix

Performance

v2.2.1 (2024-01-16)

Fix

v2.2.0 (2024-01-14)

Feature

v2.1.0 (2024-01-12)

Feature

Fix

v2.0.0 (2023-12-23)

Feature

Fix

Breaking

v1.24.0 (2023-12-21)

Feature

v1.23.0 (2023-12-18)

Feature

v1.22.0 (2023-12-14)

Feature

v1.21.0 (2023-12-14)

Feature

v1.20.0 (2023-12-13)

Feature

v1.19.0 (2023-12-12)

Feature

v1.18.0 (2023-12-10)

Fix

v1.17.0 (2023-11-24)

Feature

Fix

v1.16.1 (2023-11-09)

Fix

v1.16.0 (2023-11-08)

Fix

v1.15.4 (2023-11-05)

Fix

v1.15.3 (2023-11-05)

Fix

v1.15.2 (2023-10-18)

Fix

Performance

v1.15.1 (2023-10-04)

Fix

v1.15.0 (2023-09-30)

Feature

  • Nothing change

v1.14.0 (2023-09-26)

Feature

Fix

v1.13.2 (2023-09-12)

Fix

v1.13.1 (2023-09-11)

Fix

v1.13.0 (2023-09-07)

Feature

v1.12.0 (2023-08-31)

Feature

v1.11.0 (2023-08-26)

Feature

v1.10.1 (2023-08-19)

Fix

Performance

v1.10.0 (2023-08-03)

Feature

Performance

v1.9.0 (2023-07-18)

Feature

v1.8.0 (2023-07-17)

Fix

v1.7.0 (2023-07-14)

Feature

v1.6.1 (2023-07-10)

Fix

v1.6.0 (2023-07-06)

Feature

v1.5.0 (2023-07-04)

Fix

v1.4.0 (2023-06-30)

Feature

v1.3.1 (2023-06-29)

Fix

v1.3.0 (2023-06-29)

Feature

Fix

v1.2.0 (2023-06-24)

Feature

v1.1.0 (2023-06-23)

Feature

v1.0.0 (2023-06-21)

Breaking

Performance

v0.5.6 (2023-06-21)

Fix

v0.5.5 (2023-06-16)

Fix

v0.5.4 (2023-06-14)

Fix

v0.5.3 (2023-06-13)

Fix

v0.5.2 (2023-06-11)

Fix

v0.5.1 (2023-06-09)

Fix

v0.5.0 (2023-06-09)

Feature

v0.4.4 (2023-06-08)

Fix

  • deps: Downgrade python-semantic-release to avoid version issue

v0.4.3 (2023-06-07)

Feature

Fix

v0.4.2 (2023-06-01)

Fix

v0.4.1 (2023-05-29)

Feature

Feature

Fix

Feature

Fix

Feature

v0.1.0 (2023-02-15)

Feature

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 () ()

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 () ()

(2023-05-18)

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 () ()

(2023-04-18)

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 () ()

(2023-03-29)

Add trimEvents method () ()

queue: Add retryJobs method () ()

Initial python package ()

#3251
6a8e3e2
34dcb8c
#3245
01c62ad
#3258
1bad54a
#3243
d3b1cff
2927803
#3194
4affb11
#3218
9456472
#3190
4b96266
#3181
738d375
#3187
f16b748
0f21c10
0325a39
#3212
72fac42
#3239
e4dac2c
61395bf
#3236
192e82c
#3224
bd17aad
#3208
3c2349a
#3195
339f13e
#3201
1fbcbec
#3198
758ea26
33c62e6
#3182
8d59e3b
#3172
d57698f
#3153
219c0db
#3164
d3c397f
#3160
d91d9f4
#3223
9be6cbb
#3162
702ab38
#3228
6b37a37
#3163
5a88e47
#3145
0e137b2
83953db
#3132
c37123c
#3134
eec7114
#3098
589adb4
#3108
4b619ca
#3126
c3269b1
#3123
707853c
#3127
e0f02ce
#3116
db617e4
#3112
6a28b86
#2958
c19c914
1aa970c
#3074
05ea32b
#3036
21e8495
#2975
8bb27ea
4360572
85f6f6f
38912fb
#3052
3e990eb
#2934
71ce75c
1759c8b
ff2a47b
#2853
0f25213
b7dd925
#2822
3a4781b
#2804
9abec3d
#2796
0a4982d
#2717
a68ead9
b4e25c1
fe73f6d
7cb670e
#2758
3473054
9ef97c3
#2720
d51aabe
#2712
53bc9eb
#2711
967632c
#2708
e0d3790
de094a3
#2705
53de304
#2656
8468e44
9416501
f3290ac
509a36b
#2678
97fb97a
#2666
163ccea
8376a9a
47ba055
#2683
4441711
#2676
97a297d
#2665
93fad41
a6764ae
9d8f874
#2342
f917b80
228db2c
b89e2e0
#2607
02b8338
00cd017
#2609
6e99250
#2597
9ece15b
#2579
f957186
#2576
ca207f5
#2562
f87e3fe
238680b
d6dd21d
782382e
#2543
ae7cb6c
d81f210
6cf7712
0140959
#2532
83dfb63
5e31eb0
a24a16e
#2521
f3862dd
9693321
44f7d21
29ad8c8
64feec9
#2486
ce30192
#2483
3c335d4
#2478
b385034
34946c4
#2417
2696ef8
#2389
18ebee8
#2411
8b62d28
#2406
5923ed8
#2403
c1c2ccc
#2384
4914df8
#2408
6fb6896
#2391
ca6c17a
#2374
1813d5f
#2377
3b9de96
#1824
8ea0e1f
#2364
d5113c8
#2350
888dcc2
#2352
afb5e31
#2203
0e88e4f
4276eb7
73cf5fc
0bac0fb
#2282
8eee20f
73cf5fc
0bac0fb
#2282
8eee20f
#2345
e9c1fa1
#2340
f0a1f70
#2333
19bfccc
#2331
364f0c1
#2328
5db9f95
#2323
61f4ba3
6bb21a0
272ec69
e65b819
2cab9e9
#2242
d2e2035
568d758
76e075f
76959eb
#2261
69ece08
198bf05
#2227
c134606
#2224
1986b05
889815c
#2211
eca8c2d
#2194
3b67193
07f1335
#2188
b5e97f4
862f10b
#2175
2f5628f
4b01f35
#2174
c67dfb4
#2161
555dd44
#2115
14a769b
#2143
dcb8e6a
#2129
12ce2f3
#2108
d27f33e
#2099
c141283
#2064
841dc87
1b95185
#2066
808ee72
#2061
e255356
a557970
#2049
6d0e224
#2047
7ec1c5b
#2040
8ec9ed6
3c2d06e
#2036
92d7227
#2033
3e9db5e
#2029
d03ffc9
#2012
57b2b72
#2011
8d5d6c1
42a890a
42a890a
#2004
a55fd77
56bd7ad
a1544a8
#1975
7c5ee20
#1981
0df6afa
#1969
e753855
bb4f3b2
#1965
6a172e9
#1943
945bcd3
#1931
d97864a
#1927
ce86ece
#1906
f0867a6
v0.4.0
01f549e
#1849
5bebf8d
#1877
870da45
#1871
800b8c4
#1830
e1e1aa2
#1859
0b538ce
#1869
b044a03
#1880
01b621f
#1837
514699c
v0.3.0
#1807
46d6f94
#1809
ec7c49e
#1800
ef0c5d6
#1786
134f6ab
#1754
6bda2b2
v0.2.0
#1695
ca48163
#1688
2745327
a97b22f