taskforcesh / bullmq

89%

master: 89%

LAST BUILD ON BRANCH fix/python-flow-producer-connection

branch: fix/python-flow-producer-connection

CHANGE BRANCH

x

Reset

• fix/python-flow-producer-connection
• 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
• bullmq-pro-changelog/v7.39.3
• bullmq-pro-changelog/v7.40.0
• bullmq-pro-changelog/v7.40.3
• bullmq-pro-changelog/v7.41.0
• bullmq-pro-changelog/v7.41.1
• bullmq-pro-changelog/v7.42.0
• bullmq-pro-changelog/v7.42.1
• bullmq-pro-changelog/v7.43.0
• bullmq-pro-changelog/v7.43.1
• c8
• changelog-py-ex
• chore-brace-expansion
• chore-deps-remove-commitizen
• chore-export-child
• chore-export-lock-manager
• chore-lint-error
• chore-markdown-it
• chore-move-child-include-refactor
• chore-remove-non-needed-resolutions
• chore/add-the-sponsors-badge
• chore/refactor-lock-manager-into-separate-class
• chore/update-dev-deps
• ci-coveralls-next
• ci-fix-main-semantic-format
• ci-form-data
• ci-husky
• ci-semantic-release
• ci-simplify-release-rules
• ci-upgrade-dragonfly
• ci/add-osv-scanner
• ci/add-renovate-support
• ci/enable-oidc-npm-releases
• ci/fix-@eslint/plugin-kit-vln
• ci/fix-broken-eslint
• ci/fix-broken-npm-release
• ci/fix-elixir-release
• ci/fix-osv-scanner-workflow
• ci/fix-pr-creation-token
• ci/improve-php-release
• ci/remove-npm-token-env
• ci/remove-skip-ci
• ci/remove-skip-ci-2
• ci/separate-changelog-update-pr
• ci/upgrade-mocha-to-v11
• ci/upgrade-semantic-release
• circular-refs
• cluster-local
• copilot/add-deduplication-option-python
• copilot/fix-61b91cae-3e32-4546-845d-cdd74ead7340
• copilot/fix-61b91cae-3e32-4546-845d-cdd74ead7341
• copilot/fix-changedelay-argument-name
• copilot/fix-deduplicated-event-params
• copilot/fix-default-job-options-error
• copilot/fix-fail-parent-on-failure
• copilot/fix-keyerror-child-job-failure
• copilot/fix-queue-obliterate-bug
• copilot/update-ioredis-dependency
• copilot/update-priority-to-prioritized
• 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/npm_and_yarn-1819d6b2ed
• dependabot/npm_and_yarn/npm_and_yarn-1eb1f0b421
• dependabot/npm_and_yarn/npm_and_yarn-2082dd1f7d
• dependabot/npm_and_yarn/npm_and_yarn-420bd9ccf4
• dependabot/npm_and_yarn/npm_and_yarn-7c6ac41456
• dependabot/npm_and_yarn/npm_and_yarn-91b2e6f00a
• dependabot/npm_and_yarn/npm_and_yarn-96a93d4c45
• dependabot/npm_and_yarn/npm_and_yarn-b2936519f3
• dependabot/npm_and_yarn/npm_and_yarn-b4db131c09
• dependabot/npm_and_yarn/npm_and_yarn-c0121c9593
• dependabot/npm_and_yarn/npm_and_yarn-d15660cb19
• dependabot/npm_and_yarn/npm_and_yarn-db7721a9da
• dependabot/npm_and_yarn/npm_and_yarn-e5a595f223
• dependabot/npm_and_yarn/npm_and_yarn-ebbc90417a
• dependabot/npm_and_yarn/python/npm_and_yarn-3c67cbb9cd
• dependabot/npm_and_yarn/python/npm_and_yarn-bdc76aff73
• dependabot/npm_and_yarn/requirejs-2.3.7
• dependabot/pip/python/certifi-2024.7.4
• dependabot/pip/python/pip-99a64d02cb
• dependabot/pip/python/pip-c4ff2e68b4
• dependabot/pip/python/virtualenv-20.26.6
• deprecation-discard
• deps-remove-resolutions
• 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-5-61-2
• docs-architecture
• docs-change-delay-throws
• docs-changelog-klia
• docs-changelog-python
• docs-changelog-python-2-13
• docs-changelog-v4
• docs-dedup
• docs-fix-changelogs
• docs-fpof-clarification
• docs-local-rate-limit
• docs-maxRetriesPerRequest
• docs-nestjs-11
• docs-pro-7-26-3
• docs-pro-refs
• docs-python
• docs-stop-retrying-fix
• docs/add-job-scheduler-jsdoc
• docs/complete-missing-jsdoc-descriptions
• docs/fix-job-class-jsdoc
• docs/fix-link-to-use-https
• docs/framework
• docs/typos
• drain-python
• elixir-scheduler-upsert-fix
• enhance-getDependencyCounts
• event-producer-fix-args-stringify
• feat-complete-span
• feat-elixir-retry
• feat-failed-getFlow
• feat-gauge-metric
• feat-get-flow-ignored
• feat-get-global-config
• feat-get-global-rate-limit
• 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-obliterate-elixir
• feat-remove-global-rate-limit
• feat-restore-limit
• feat-retry-reset-options
• feat-sandbox-esm
• feat-save-offset
• feat-stalledCounter
• feat-support-replace-single-mode
• feat-test-worker-extends-job-lock
• feat/add-cancel-support-sandboxed-processors
• feat/add-continue-parent-on-failure
• feat/add-deduplicated-job-id-to-deduplicated-event
• feat/add-generic-type-to-job-data
• feat/add-php-queue-support
• feat/add-prometheus-exporter
• feat/add-queue-registry-support
• feat/add-remove-unprocessed-children
• feat/add-sandbox-support-for-get-children-values
• feat/add-simple-job-cancellation-feature
• feat/add-skip-waiting-connection-option
• feat/convert-moveToFailed-to-a-lua-script
• feat/dedicated-thread-lock-extension
• feat/grouped-rate-limiter
• feat/implement-elixir-version
• feat/improved-telemetry-spans
• feat/otel-metrics
• feat/promote-reccuring-job-test-case
• feat/redis-driver-info
• feat/requeue-deduplication-mode
• feat/requeue-deduplication-modev2
• feat/revert-add-delayed-job-and-update-in-same-script
• feat/sandbox-get-dependencies
• feat/sandbox-get-dependencies-count
• 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-event-manual-processing
• fix-active-jobs-when-closing-or-pausing
• fix-add-job-scheduler
• fix-apply-limit-remove-age
• fix-attempts-made-telemetry
• fix-avoid-circular-ref
• fix-brace-expansion
• fix-changedelay-argument-name
• fix-check-current-producer
• fix-clean-job-schedulers
• fix-cluster-drain
• fix-comment-typo
• fix-consider-fpof-when-parent-no-in-wc
• fix-datatype
• fix-dedup-flows
• fix-dedup-root-parent
• fix-deduplication-removal
• fix-defa-rate-limit
• fix-defa-stalled
• fix-default-message-for-errors
• fix-delay-scheduler
• fix-deps-eslint
• fix-deps-eslint@9.32.0
• fix-do-not-retry-processor-on-connection-error
• fix-duplicated-event-update-js
• fix-dynamic-rate-limit
• fix-emit-error-once
• fix-endDate-check
• fix-every-delays
• fix-export-processor
• fix-failed-children
• fix-flaky-test
• fix-flow-debounce
• fix-flow-delayed
• fix-flow-fail-parent
• fix-flow-prioritized
• fix-get-dependencies
• fix-get-flow-default-prefix
• fix-getjobscheduler-return-type
• fix-ioredis-5-9
• fix-issue-3699
• fix-job-scheduler-data
• fix-jobjsonsandbox-remove-returnvalue
• fix-js-remove-current-job
• fix-legacy-repeat
• fix-limit-removeJobsByMaxAge
• fix-lua-scripts-elixir
• fix-maxStalledCount
• fix-maximumRateLimitDelay
• fix-meta-children
• fix-only-emit-error-when-move-to-active-failed
• fix-pending-children-completed
• fix-prev-on-retry
• fix-priority-serialization
• fix-python-connection-type
• fix-python-moveToFailed
• fix-queue-progress-event
• fix-rate-limit-consider-job-deletion
• fix-readme-typo
• fix-remove-child-from-dependencies
• fix-removed-event
• fix-reprocessjob-parent
• fix-resume
• fix-retry-save-error
• fix-returning-job-data-docs
• 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-stalled-extend-locks
• fix-start-data-scheduler
• fix-timestamp-process-spans
• fix-tmp-vulnerability
• fix-types-path
• fix-undefined-getjobs
• fix-upgrade-uuid
• fix-validate-deid
• fix/3703
• fix/3878-flow-dedup-jobid-mapping
• fix/add-marker-when-upserting-job-scheduler-if-needed
• fix/avoid-possible-hazard-in-close-worker
• fix/bzpopmin-race-condition
• fix/correct-php-release
• fix/deduplicated-event-docs-3523
• fix/delayed-event-docs-and-type
• 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/error-forwarding-repeat-jobscheduler
• fix/filter-inspect-publish-uid
• fix/fix-3289
• fix/fix-duplicate-connection-scheduler
• fix/fix-elixir-job-schedulers
• fix/fix-elixir-release-lua-scripts
• fix/fix-leave-orphane-jobs-in-autoremove
• fix/fix-release-action
• fix/fix-return-type-of-getNextJob
• fix/fix-scheduler-4096
• fix/fix-tslib-dep
• fix/fix-unstable-upsert-job-scheduler
• fix/flow-deduplication-consistency
• fix/flow-producer-check-exec-errors
• fix/flow-producer-connection-3619
• fix/flow-producer-getFlow-return-type
• fix/flow-producer-silent-exec-failure
• fix/get-jobs-filter-undefined
• fix/get-version/3204
• fix/guarantee-every-repeatable-jobs-slotted
• fix/job-scheduler-empty-hash-fallback
• fix/job-scheduler-preserve-offset
• fix/lock-manager-spanKind-type
• 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/prefer-native-abort
• fix/prometheus-metrics-with-removal
• fix/propagation-metadata-typo
• fix/prune-both-finished-sets
• fix/python-connection-pool-limits
• fix/python-process-job-key-error
• fix/python-worker-close-fault-tolerant
• fix/queue-type-inference
• fix/remove-child-from-pool-when-exit
• fix/remove-race-condition-when-starting-sandboxed-processor-with-abort-signal
• fix/repeat-options-typo
• fix/reset-iterations-when-changing-every-setting
• fix/return-closing-promise-in-worker
• fix/sandboxed-job-missing-type-declarations
• fix/skip-rate-limiter-get-when-disabled
• fix/support-waiting-and-wait
• fix/upsertJobScheduler-do-not-apply-change
• fix/wait-fetched-jobs-to-be-processed-when-closing
• fix/worker-closed-event-jsdoc
• fix/worker-connection-name-on-cluster
• flow-remove-active
• global-rate-limiter
• infinity-retry-connection-error
• iteration-count
• jitter
• job-remove-deduplication-key
• job-scheduler-ic
• js-yaml-vul
• lazy-error-move-to-waiting-children
• lazy-parent-failure
• lock-flaky-test
• manast-patch-1
• master
• metrics
• migrations-docs
• minimatch-vul
• move-provenance
• 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-move-to-active-manual-movement
• perf-move-to-delayed-fetch-next
• perf-worker-keep-lower-blockTimeout
• performance/some-elixir-performance-improvements
• prefix-clarification
• python-dev-dep
• python-pytest
• python-rate-limit
• python-retry-if-failed
• queue-search
• redis-types
• refactor-add-job-scheduler
• refactor-add-parent-job
• refactor-args-for-extension
• refactor-dedup
• refactor-handler-callbacks
• refactor-opts-decode-encode
• refactor-pause-worker
• refactor-remove-truthy-checks
• refactor-sandbox-extension
• 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/v5.60.0
• release/v5.61.0
• release/v5.61.2
• release/v5.62.0
• release/v5.62.1
• release/v5.62.2
• release/v5.63.0
• release/v5.63.1
• release/v5.63.2
• release/v5.64.0
• release/v5.64.1
• release/v5.65.0
• release/v5.65.1
• release/v5.66.0
• release/v5.66.1
• release/v5.66.2
• release/v5.66.3
• release/v5.66.4
• release/v5.66.5
• release/v5.66.6
• release/v5.66.7
• release/v5.67.0
• release/v5.67.1
• release/v5.67.2
• release/v5.67.3
• release/v5.68.0
• release/v5.69.0
• release/v5.69.1
• release/v5.69.3
• release/v5.69.4
• release/v5.70.0
• release/v5.70.1
• release/v5.70.2
• release/v5.70.3
• release/v5.70.4
• release/v5.71.0
• release/v5.71.1
• release/v5.72.1
• release/v5.73.0
• release/v5.73.1
• release/vex1.0.1
• release/vex1.1.0
• release/vex1.2.0
• release/vex1.2.1
• release/vex1.2.2
• release/vex1.2.3
• release/vex1.2.4
• release/vex1.2.5
• release/vex1.2.6
• release/vex1.2.7
• release/vex1.3.0
• release/vphp1.0.1
• release/vphp1.0.2
• release/vpy2.16.0
• release/vpy2.16.1
• release/vpy2.16.2
• release/vpy2.17.0
• release/vpy2.18.0
• release/vpy2.18.1
• release/vpy2.18.2
• release/vpy2.18.3
• release/vpy2.19.0
• release/vpy2.19.1
• release/vpy2.19.2
• release/vpy2.19.3
• release/vpy2.19.5
• release/vpy2.19.6
• release/vpy2.19.7
• release/vpy2.19.8
• release/vpy2.20.0
• remove-ac-and-uuid
• remove-global-concurrency
• remove-resolutions
• remove-types-uuid
• renovate-osv
• renovate/actions-cache-5.x
• renovate/actions-checkout-6.x
• renovate/actions-checkout-digest
• renovate/actions-setup-node-6.x
• renovate/actions-setup-node-digest
• renovate/actions-setup-python-6.x
• renovate/actions-setup-python-digest
• renovate/build-0.x
• renovate/build-1.x
• renovate/chai-6.x
• renovate/coverallsapp-github-action-digest
• renovate/devdependencies-(non-major)
• renovate/docker.dragonflydb.io-dragonflydb-dragonfly-1.x
• renovate/elixir-dependencies
• renovate/eslint
• renovate/github-codeql-action-4.x
• renovate/github-codeql-action-digest
• renovate/globals-17.x
• renovate/google-osv-scanner-action-2.x
• renovate/husky-9.x
• renovate/ioredis-5.x
• renovate/lock-file-maintenance
• renovate/major-elixir-dependencies
• renovate/major-eslint
• renovate/major-python-dependencies
• renovate/minimatch-10.x
• renovate/msgpackr-1.x
• renovate/node-22.x
• renovate/node-24.x
• renovate/npm-minimatch-vulnerability
• renovate/peaceiris-actions-gh-pages-4.x
• renovate/php-dependencies
• renovate/pin-dependencies
• renovate/pipenv-2023.x
• renovate/pre-commit-3.x
• renovate/pre-commit-4.x
• renovate/pypi-filelock-vulnerability
• renovate/pypi-virtualenv-vulnerability
• renovate/python-3.x
• renovate/python-dependencies
• renovate/redis-8.x
• renovate/semver-7.x
• renovate/supercharge-redis-github-action-1.x
• renovate/types-redis-4.x
• renovate/typescript-type-definitions
• renovate/undici-7.x
• restore-old-scheduler-format
• revert-226-patch-3
• sandbox_moveToWaitingChildren
• scheduler-flaky-test
• scripts-instances-python
• semantic-release-elixir
• slicing
• test-address-vitest-style
• test-clean-completed-job-scheduler
• test-clean-flaky
• test-closing
• test-delay-until-type
• test-duplicated-scheduler
• 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-stalled-retry
• 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
• test/port-mocha-to-vitest
• testing-section
• tests-local-python
• update-job-scheduler
• update-progress
• update-scheduler
• update-script-loader
• updateSemverVersion
• upgrade-prettier
• v6
• vul-picomatch
• vul-undici
• wait-pipeline-removeAllQueueData
• worker-failed-fetch-next

Build # 24131501282

Build Type

Pull #3964

github

Committed by web-flow

Commit Message

Merge 12cf7b645 into 9224dc029

Pull Request Pull Request #3964: fix(python): use connection from opts in FlowProducer

Coverage Stats

1489 of 1735 branches covered (85.82%)

Branch coverage included in aggregate %.

2806 of 3086 relevant lines covered (90.93%)

4485.67 hits per line