Changelogs
Last updated
Was this helpful?
Last updated
Was this helpful?
flow: change parent failure in a lazy way () ()
flow-producer: use FlowProducer prefix by defualt when calling getFlow () ()
job: expose stalledCounter attribute () ()
made line split more compatible () (), closes
Nothing change, triggered by a python version release
worker: Markers use now a dedicated key in redis instead of using a special Job ID.
references:
add removeUnprocessedChildren () ()
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 () ()
flows: add continueParentOnFailure option () ()
queue-events: pass right path for JobProgress type () fixes ()
updateProgress: allow more types to be used as progress () ()
flow: validate pending dependencies before removing lock () ()
job-scheduler: emit duplicated event when next delayed job exists () ()
add deduplicated job id to the deduplicated event ()
scheduler: remove next delayed job when possible () ()
flow: only validate pending dependencies when moving to completed () ()
flow: validate parentKey existence before trying to move it to failed () ()
flow: consider prioritized state when moving a parent to failed () ()
prometheus export: expose global variables ()
job-scheduler: add marker when upserting job scheduler if needed () ()
job: support ignored and failed counts in getDependenciesCount () ref ()
flow: consider to fail a parent not in waiting-children when failParentOnFailure is provided () ()
job-scheduler: restore iterationCount attribute () ()
job: add complete span in moveToCompleted method () ()
worker: optimize job retrieval for failed jobs in chunks () ()
scheduler: remove multi when updating a job scheduler () ()
job: deserialize priority in fromJSON () ()
worker: cast delay_until to integer [python] () ()
scheduler: validate repeatKey if present when cleaning failed jobs () fixes ()
flow: consider delayed state when moving a parent to failed () ()
telemetry: fix span name for moveToFailed logic () ()
job-scheduler: consider removing current job from wait, paused or prioritized () ()
delayed: add marker once when promoting delayed jobs () (python) ()
worker: do not execute run method when no processor is defined when resuming () ()
worker: do not resume when closing () ()
job: set processedBy when moving job to active in moveToFinished () fixes ()
job: add moveToWait method for manual processing () ()
queue: support removeGlobalConcurrency method () ()
add-job: add job into wait or prioritized state when delay is provided as 0 () ()
drain: pass delayed key for redis cluster () ()
job-scheduler: restore limit option to be saved () ()
job-scheduler: return undefined in getJobScheduler when it does not exist () fixes ()
fix return type of getNextJob ()
worker: wait fetched jobs to be processed when closing () ()
job-scheduler: revert add delayed job and update in the same script ()
worker: evaluate if a job needs to be fetched when moving to failed () ()
retry-job: consider updating failures in job () ()
job-scheduler: save limit option () ()
flow-producer: add support for skipWaitingForReady ()
queue: add option to skip wait until connection ready ()
queue-getters: add prometheus exporter ()
job-scheduler: save iteration count () ()
worker: avoid possible hazard in closing worker ()
sandbox: add support for getChildrenValues ()
job-scheduler: use delayed job data when template data is not present () fixes ()
job-scheduler: add next delayed job only when prevMillis matches with producerId () ()
job-scheduler: add delayed job and update scheduler in same script () ()
job-scheduler: add delayed job and scheduler in same script () ()
job-scheduler: avoid duplicates when upserting in a quick sequence () ()
dynamic-rate-limit: validate job lock cases () ()
sandbox: fix issue where job could stay in active forever () ()
sandboxed: fix detecting special errors by sending default messages () fixes ()
scripts: make sure jobs fields are not empty before unpack ()
guarantee every repeatable jobs are slotted ()
job-scheduler: avoid duplicated delayed jobs when repeatable jobs are retried ()
telemetry: add option to omit context propagation on jobs () ()
job-scheduler: omit deduplication and debounce options from template options () ()
replace multi by lua scripts in moveToFailed () ()
queue: enhance getJobSchedulers method to include template information () ref ()
worker: catch connection error when moveToActive is called () ()
scheduler-template: remove console.log when getting template information () ()
queue: enhance getJobScheduler method to include template information () ref ()
flow: allow using removeOnFail and failParentOnFailure in parents () fixes ()
job-scheduler: upsert template when same pattern options are provided () ref ()
queue: add getJobSchedulersCount method () ()
scheduler: remove deprecation warning on immediately option () ()
queue: refactor a protected addJob method allowing telemetry extensions ()
queue: change _jobScheduler from private to protected for extension () ()
scheduler: use Job class from getter for extension () ()
job-scheduler: add telemetry support to the job scheduler ()