github taskforcesh/bullmq vpy2.11.0

12 hours ago

Feature

  • queue: Add getDelayedCount method [python] (#2934) (71ce75c)
  • queue: Refactor a protected addJob method allowing telemetry extensions (09f2571)
  • job-scheduler: Add telemetry support to the job scheduler (72ea950)
  • queue: Add rateLimit method (#2896) (db84ad5)
  • queue: Add removeRateLimitKey method (#2806) (ff70613)
  • Improve queue getters to use generic job type (#2905) (c9531ec)
  • queue-events: Add QueueEventsProducer for publishing custom events (#2844) (5eb03cd)
  • flows: Add telemetry support (#2879) (5ed154b)
  • scheduler: Add getJobScheduler method (#2877) ref #2875 (956d98c)
  • queue: Add a telemetry interface (#2721) (273b574)

Fix

  • scheduler: Remove deprecation warning on immediately option (#2923) (14ca7f4)
  • queue: Change _jobScheduler from private to protected for extension (#2920) (34c2348)
  • scheduler: Use Job class from getter for extension (#2917) (5fbb075)
  • telemetry: Do not set span on parent context if undefined (c417a23)
  • queue: Fix generics to be able to properly be extended (f2495e5)
  • job-scheculer: Avoid hazards when upserting job schedulers concurrently (022f7b7)
  • connection: Do not allow to set blockingConnection option (#2851) (9391cc2)
  • repeatable: Only apply immediately in the first iteration (f69cfbc)
  • scripts: Set package version by default for extension (#2887) (b955340)
  • worker: Allow retrieving concurrency value (#2883) fixes #2880 (52f6317)
  • connection: Set packageVersion as protected attribute for extension (#2884) (411ccae)
  • deps: Bump msgpackr to 1.1.2 to resolve ERR_BUFFER_OUT_OF_BOUNDS error (#2882) ref #2747 (4d2136c)

Documentation

Performance

  • marker: Add base markers while consuming jobs to get workers busy (#2904) fixes #2842 (1759c8b)

Don't miss a new bullmq release

NewReleases is sending notifications on new releases.