taskforcesh / bullmq

89%

master: 89%

LAST BUILD ON BRANCH fix/bzpopmin-race-condition

branch: fix/bzpopmin-race-condition

CHANGE BRANCH

x

Reset

• fix/bzpopmin-race-condition
• add-custom-job-id-validation
• add-delayed-job-scheduler
• apply-pytest-timeout
• build-publish-wheels
• bullmq-pro-changelog-split
• bullmq-pro-changelog/v7.38.4
• bullmq-pro-changelog/v7.38.5
• bullmq-pro-changelog/v7.39.0
• chore-export-child
• chore-lint-error
• chore-remove-non-needed-resolutions
• chore/update-dev-deps
• ci-coveralls-next
• ci-fix-main-semantic-format
• ci-form-data
• ci-semantic-release
• ci/add-osv-scanner
• ci/fix-@eslint/plugin-kit-vln
• ci/fix-broken-eslint
• ci/fix-osv-scanner-workflow
• ci/fix-pr-creation-token
• ci/remove-skip-ci
• ci/remove-skip-ci-2
• ci/separate-changelog-update-pr
• ci/upgrade-mocha-to-v11
• circular-refs
• cron-parser
• deduplicate-job-schedulers
• deduplication-pattern
• deno_investigation
• dependabot/npm_and_yarn/braces-3.0.3
• dependabot/npm_and_yarn/jquery-3.5.1
• dependabot/npm_and_yarn/lodash-4.17.19
• dependabot/npm_and_yarn/npm-6.13.4
• dependabot/npm_and_yarn/npm-6.14.6
• dependabot/npm_and_yarn/requirejs-2.3.7
• dependabot/pip/python/certifi-2024.7.4
• dependabot/pip/python/virtualenv-20.26.6
• deprecation-discard
• do-not-resume-when-closing
• doc/fix-broken-link-to-contributing
• docs-5-53-3
• docs-5-54-0
• docs-5-54-1
• docs-5-54-2
• docs-changelog-python
• docs-changelog-python-2-13
• docs-changelog-v4
• docs-dedup
• docs-fpof-clarification
• docs-local-rate-limit
• docs-maxRetriesPerRequest
• docs-nestjs-11
• docs-pro-7-26-3
• docs-pro-refs
• docs-stop-retrying-fix
• docs/fix-link-to-use-https
• enhance-getDependencyCounts
• event-producer-fix-args-stringify
• feat-complete-span
• feat-failed-getFlow
• feat-get-flow-ignored
• feat-get-ignored-children-values
• feat-get-job-schedulers-template-data
• feat-get-waiting-count-python
• feat-job-move-to-completed
• feat-job-progress-getter-for-sanboxed-processors
• feat-limit-job-scheduler
• feat-manual-move-to-wait
• feat-maxStartAttempts
• feat-restore-limit
• feat-sandbox-esm
• feat-save-offset
• feat-stalledCounter
• feat-support-replace-single-mode
• feat-test-worker-extends-job-lock
• feat/add-continue-parent-on-failure
• feat/add-deduplicated-job-id-to-deduplicated-event
• feat/add-generic-type-to-job-data
• feat/add-prometheus-exporter
• feat/add-queue-registry-support
• feat/add-remove-unprocessed-children
• feat/add-sandbox-support-for-get-children-values
• feat/add-skip-waiting-connection-option
• feat/convert-moveToFailed-to-a-lua-script
• feat/dedicated-thread-lock-extension
• feat/grouped-rate-limiter
• feat/otel-metrics
• feat/promote-reccuring-job-test-case
• feat/revert-add-delayed-job-and-update-in-same-script
• feat/telemetry-option-omit-context
• feat/worker-otel-attributes
• fix-102-get-rid-of-flushdb-in-tests
• fix-104-improve-error-handling
• fix-72-default-maxLenEvents-in-move-to-finished-lua
• fix-active-jobs-when-closing-or-pausing
• fix-add-job-scheduler
• fix-avoid-circular-ref
• fix-brace-expansion
• fix-check-current-producer
• fix-clean-job-schedulers
• fix-cluster-drain
• fix-consider-fpof-when-parent-no-in-wc
• fix-deduplication-removal
• fix-defa-rate-limit
• fix-defa-stalled
• fix-default-message-for-errors
• fix-deps-eslint
• fix-deps-eslint@9.32.0
• fix-duplicated-event-update-js
• fix-dynamic-rate-limit
• fix-endDate-check
• fix-every-delays
• fix-export-processor
• fix-failed-children
• fix-flaky-test
• fix-flow-delayed
• fix-flow-fail-parent
• fix-flow-prioritized
• fix-get-dependencies
• fix-get-flow-default-prefix
• fix-getjobscheduler-return-type
• fix-job-scheduler-data
• fix-js-remove-current-job
• fix-legacy-repeat
• fix-maxStalledCount
• fix-meta-children
• fix-pending-children-completed
• fix-prev-on-retry
• fix-priority-serialization
• fix-python-connection-type
• fix-python-moveToFailed
• fix-rate-limit-consider-job-deletion
• fix-readme-typo
• fix-remove-child-from-dependencies
• fix-reprocessjob-parent
• fix-resume
• fix-retry-save-error
• fix-scheduler-do-not-update-data
• fix-scheduler-does-not-exist
• fix-scheduler-no-add-existing-job
• fix-scheduler-omit-deduplication-opts
• fix-scheduler-remove
• fix-scheduler-remove-next-delayed-job
• fix-skip-version-check
• fix-slot
• fix-span-move-to-failed
• fix-stacktrace
• fix-start-data-scheduler
• fix-tmp-vulnerability
• fix-types-path
• fix-undefined-getjobs
• fix-upgrade-uuid
• fix-validate-deid
• fix/add-marker-when-upserting-job-scheduler-if-needed
• fix/avoid-possible-hazard-in-close-worker
• fix/delete-jobs-when-cleaning-in-set
• fix/divide-timestamp-in-update-delay-set
• fix/do-not-skip-job-to-process-when-closing
• fix/duplicate-connection-in-scheduler
• fix/edge-case-job-lock-not-renewed-in-time
• fix/fix-3289
• fix/fix-duplicate-connection-scheduler
• fix/fix-return-type-of-getNextJob
• fix/fix-scheduler-4096
• fix/fix-tslib-dep
• fix/fix-unstable-upsert-job-scheduler
• fix/get-version/3204
• fix/guarantee-every-repeatable-jobs-slotted
• fix/make-sure-fields-to-update-is-nil
• fix/memory-leak-wait-for-job-2
• fix/move-to-delayed-docstring
• fix/multiple-delayed-jobs-upserting-succession
• fix/omit-telemetry-option-for-classes-that-do-not-use-them
• fix/otel-attributes
• fix/queue-type-inference
• fix/remove-child-from-pool-when-exit
• fix/return-closing-promise-in-worker
• fix/support-waiting-and-wait
• fix/wait-fetched-jobs-to-be-processed-when-closing
• flow-remove-active
• global-rate-limiter
• infinity-retry-connection-error
• iteration-count
• jitter
• job-scheduler-ic
• lazy-error-move-to-waiting-children
• lazy-parent-failure
• lock-flaky-test
• master
• migrations-docs
• move-stalled-jobs-to-wait-performance
• olaf/sandbox_getIgnoredChildrenFailures
• patch-1
• pb-job-succession
• perf-add-marker-once-delayed-promotion
• perf-add-marker-once-delayed-promotion-v4
• perf-delay-0
• perf-do-not-wait-when-fetching-jobs
• perf-exists-parent-failed
• perf-get-metrics
• perf-manual-movement
• perf-worker-keep-lower-blockTimeout
• prefix-clarification
• python-pytest
• python-rate-limit
• refactor-add-job-scheduler
• refactor-args-for-extension
• refactor-dedup
• refactor-handler-callbacks
• refactor-opts-decode-encode
• refactor-pause-worker
• refactor-remove-truthy-checks
• refactor-store-job-scheduler-include
• release/v5.54.3
• release/v5.55.0
• release/v5.56.0
• release/v5.56.1
• release/v5.56.10
• release/v5.56.2
• release/v5.56.3
• release/v5.56.4
• release/v5.56.5
• release/v5.56.6
• release/v5.56.7
• release/v5.56.8
• release/v5.56.9
• release/v5.57.0
• release/v5.58.0
• release/v5.58.1
• release/v5.58.2
• release/v5.58.3
• release/v5.58.4
• release/v5.58.5
• release/v5.58.6
• release/v5.58.7
• release/v5.59.0
• release/vpy2.16.0
• release/vpy2.16.1
• remove-ac-and-uuid
• remove-global-concurrency
• renovate/pipenv-2023.x
• revert-226-patch-3
• sandbox_moveToWaitingChildren
• scheduler-flaky-test
• slicing
• test-clean-completed-job-scheduler
• test-clean-flaky
• test-closing
• test-delay-until-type
• test-duplicated-scheduler-pattern
• test-fix-flaky-test
• test-flaky
• test-flaky-test
• test-flaky-worker-dragonfly
• test-flow-flaky
• test-job-scheduler-and-priority
• test-remove-unprocessed-children
• test-sandboxed-child-ref
• test/add-another-edge-case-for-job-schedulers
• test/add-test-case-for-updating-repeated-job-data
• test/add-test-for-sandbox-ttl-pattern
• test/improve-test-get-failed
• test/improve-test-rejection
• update-job-scheduler
• update-progress
• update-scheduler
• updateSemverVersion
• upgrade-prettier
• v6
• worker-failed-fetch-next

Build # 16061724108

Build Type

Pull #3326

github

Committed by web-flow

Commit Message

Merge f7ce6b6af into 1f43976e0

Pull Request Pull Request #3326: fix(worker): fix bzpopmin race condition

Run Details

1431 of 1703 branches covered (84.03%)

Branch coverage included in aggregate %.

3 of 3 new or added lines in 1 file covered. (100.0%)

2798 of 3057 relevant lines covered (91.53%)

1973.79 hits per line