feat: expand Queue/Job/Worker API parity with Node.js BullMQ [rust]

.github/workflows/elixir-test.yml

@@ -31,7 +31,6 @@ jobs:
 
   test:
     needs: changes
-    if: needs.changes.outputs.should_run == 'true'
     runs-on: ubuntu-latest
 
     name: testing elixir@${{ matrix.elixir-version }}, otp@${{ matrix.otp-version }}, redis@${{ matrix.redis-version }}
@@ -44,31 +43,43 @@ jobs:
         redis-version: [7-alpine]
 
     steps:
+      - name: Skip when Elixir files are unchanged
+        if: needs.changes.outputs.should_run != 'true'
+        run: echo "No Elixir-related changes detected; skipping Elixir test steps."
+
       - name: Checkout repository
+        if: needs.changes.outputs.should_run == 'true'
         uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6
 
       - name: Use Node.js ${{ matrix.node-version }}
+        if: needs.changes.outputs.should_run == 'true'
         uses: actions/setup-node@48b55a011bda9f5d6aeb4c2d9c7362e8dae4041e # v6
         with:
           node-version: ${{ matrix.node-version }}
           cache: 'yarn'
 
       - name: Start Redis
+        if: needs.changes.outputs.should_run == 'true'
         uses: supercharge/redis-github-action@bc274cb7238cd63a45029db04ee48c07a72609fd # 1.8.1
         with:
           redis-version: ${{ matrix.redis-version }}
 
-      - run: yarn install --ignore-engines --frozen-lockfile --non-interactive
-      - run: yarn generate:raw:scripts
-      - run: yarn copy:lua:elixir
+      - if: needs.changes.outputs.should_run == 'true'
+        run: yarn install --ignore-engines --frozen-lockfile --non-interactive
+      - if: needs.changes.outputs.should_run == 'true'
+        run: yarn generate:raw:scripts
+      - if: needs.changes.outputs.should_run == 'true'
+        run: yarn copy:lua:elixir
 
       - name: Set up Elixir
+        if: needs.changes.outputs.should_run == 'true'
         uses: erlef/setup-beam@v1
         with:
           elixir-version: ${{ matrix.elixir-version }}
           otp-version: ${{ matrix.otp-version }}
 
       - name: Restore dependencies cache
+        if: needs.changes.outputs.should_run == 'true'
         uses: actions/cache@v5
         with:
           path: elixir/deps
@@ -77,20 +88,24 @@ jobs:
             ${{ runner.os }}-mix-deps-${{ matrix.elixir-version }}-${{ matrix.otp-version }}-
 
       - name: Install Elixir dependencies
+        if: needs.changes.outputs.should_run == 'true'
         working-directory: elixir
         run: |
           mix local.hex --force
           mix local.rebar --force
           mix deps.get
 
       - name: Compile
+        if: needs.changes.outputs.should_run == 'true'
         working-directory: elixir
         run: mix compile --warnings-as-errors
 
       - name: Run tests
+        if: needs.changes.outputs.should_run == 'true'
         working-directory: elixir
         run: mix test --include integration
 
       - name: Check formatting
+        if: needs.changes.outputs.should_run == 'true'
         working-directory: elixir
         run: mix format --check-formatted

.github/workflows/osv-scanner.yml

@@ -20,6 +20,7 @@ jobs:
   scan-scheduled:
     uses: 'google/osv-scanner-action/.github/workflows/osv-scanner-reusable.yml@v2.3.5'
     with:
+      fail-on-vuln: ${{ github.event_name == 'schedule' }}
       scan-args: |-
         --config=osv-scanner.toml
         -r

docs/gitbook/rust/changelog.md

@@ -18,3 +18,12 @@
 - Job deduplication support and remove_deduplication_key
 - Worker handling for RateLimited/NextTimestamp fetch results
 - Cron scheduler support via croner and chrono-tz
+- FlowProducer: add, add_bulk, add_with_opts (per-queue default job options), get_flow
+- Flows: failParentOnFailure, removeDependencyOnFailure, ignoreDependencyOnFailure, continueParentOnFailure
+- Queue getters: get_jobs, get_ranges, get_waiting/active/delayed/completed/failed/prioritized/waiting_children
+- Queue counts: count, get_job_counts_by_types, get_job_count_by_types, get_counts_per_priority, per-state count getters
+- Queue: get_rate_limit_ttl, get_global_concurrency, get_global_rate_limit, get_deduplication_job_id
+- Queue: get_metrics (time-series), get_dependencies_count, get_children_values
+- Job: clear_logs, discard, is_waiting_children, get_ignored_children_failures, get_dependencies, move_to_waiting_children
+- Worker: metrics option (time-series collection), rate limiting
+- Connections: typed options (host/port/username/password/db) and TLS (`rediss://`) support

docs/gitbook/rust/introduction.md

@@ -190,6 +190,24 @@ let worker = Worker::new("my-queue", processor, WorkerOptions {
 }).await?;
 ```
 
+Instead of a URL you can use typed connection fields. When `host` is set, the
+URL is built from these fields (use `tls: true` for a `rediss://` TLS
+connection):
+
+```rust
+use bullmq::options::RedisConnectionOptions;
+
+let conn = RedisConnectionOptions {
+    host: Some("redis.example.com".to_string()),
+    port: Some(6380),
+    username: Some("user".to_string()),
+    password: Some("password".to_string()),
+    db: Some(0),
+    tls: true,
+    ..Default::default()
+};
+```
+
 ## Key Differences from Node.js
 
 | Aspect         | Node.js                            | Rust                                                   |

osv-scanner.toml

@@ -1,4 +1,11 @@
 # OSV Scanner Configuration
 # https://google.github.io/osv-scanner/configuration/
 
+# rustls-pemfile is unmaintained (the crate was archived; its PEM parsing was
+# folded into rustls-pki-types). This is an informational advisory with no CVSS
+# score and no fixed version available. It is only pulled in transitively by the
+# `redis` crate's TLS support (rust/Cargo.lock) and there is nothing to upgrade
+# to, so we acknowledge and ignore it.
 [[IgnoredVulns]]
+id = "RUSTSEC-2025-0134"
+reason = "Informational only (unmaintained). Transitive via redis TLS; no fixed version available."