Home / taskforcesh / bullmq
AI Slop Code RIsk Monitor

taskforcesh/bullmq

BullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL

8.2 Moderate pattern signal View on GitHub

Maintenance and Governance Review

This report summarizes scanner evidence for taskforcesh/bullmq, a TypeScript project with 9,491 GitHub stars. SynthScan examined 183,458 lines of code across 771 source files, recording 917 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 8.2 (Moderate pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

8.2
Adjusted Signal
8.2
Raw Pattern Score
100%
Time Factor
2026-10-10
Last Push
9.5K
Stars
TypeScript
Language
183.5K
Lines of Code
771
Files
917
Pattern Hits
2026-10-12
Scan Date
0.02
HC Hit Rate

Risk Review · v3

Use each vector to guide manual verification of the underlying findings.

Cognitive Ownership Risk 9.6/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 332 finding(s).

Hallucinated Dependency & Supply Chain Risk 1.8/100 · LOW

Are imports declared and package/API names verified? 69 finding(s).

Agent Over-Engineering Ratio 29.7/100 · MEDIUM

Are wrappers, guards, and repeated structures necessary? 729 finding(s).

PR Review Velocity Impact 40.9/100 · MEDIUM

Which changes need focused human review? 917 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 0HIGH 17MEDIUM 463LOW 437

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 917 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Decorative Section Separators450 hits · 940 pts
SeverityFileLineSnippetContext
MEDIUM⚡python/bullmq/backend.py339 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backend.py341 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backend.py351 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backend.py353 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backend.py362 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backend.py364 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py41 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py43 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py92 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py94 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py114 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py116 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py142 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py144 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py214 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py216 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py251 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py253 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py265 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py267 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py287 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py289 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/postgres_backend.py751 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/postgres_backend.py753 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/postgres_backend.py761 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/postgres_backend.py763 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py236 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py238 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py279 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py281 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py297 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py299 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py389 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py391 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py561 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py563 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py603 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py605 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py619 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py621 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py645 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py647 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py827 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py829 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py290 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py292 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py302 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py304 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py406 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py408 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py418 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py420 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py425 # ============================================================COMMENT
MEDIUM⚡python/bullmq/backends/redis_backend.py427 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py86 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py88 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py149 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py151 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py167 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py169 # ============================================================COMMENT
390 more matches not shown…
Hyper-Verbose Identifiers210 hits · 216 pts
SeverityFileLineSnippetContext
LOWpython/tests/redis_connection_cluster_test.py9 async def test_set_client_name_non_cluster(self):CODE
LOWpython/tests/redis_connection_cluster_test.py20 async def test_set_client_name_cluster(self):CODE
LOWpython/tests/postgres_backend_test.py21 def test_row_to_job_map_json_encodes_plain_strings(self):CODE
LOWpython/tests/postgres_backend_test.py42 def test_job_from_json_round_trips_plain_string_fields(self):CODE
LOWpython/tests/postgres_backend_test.py65 def test_client_name_includes_schema_namespace(self):CODE
LOWpython/tests/postgres_backend_test.py74 async def test_move_to_failed_keeps_failed_reason_as_raw_text(self):CODE
LOWpython/tests/postgres_backend_test.py144 async def test_returns_last_applied_migration_version(self):CODE
LOWpython/tests/postgres_backend_test.py162 def test_quote_schema_name_error_message_mentions_dollar_signs(self):CODE
LOWpython/tests/postgres_backend_test.py169 async def test_ensure_job_channel_listens_once_per_connection(self):CODE
LOWpython/tests/postgres_backend_test.py183 async def test_ensure_job_channel_relistens_after_reconnect(self):CODE
LOWpython/tests/postgres_backend_test.py201 async def test_reset_job_channel_forces_new_listen_connection(self):CODE
LOWpython/tests/postgres_backend_test.py219 async def test_listen_connection_applies_last_application_name_when_created(self):CODE
LOWpython/tests/postgres_backend_test.py249 async def test_listen_connection_enables_tcp_keepalives(self):CODE
LOWpython/tests/postgres_backend_test.py267 async def test_set_application_name_updates_existing_listen_connection(self):CODE
LOWpython/tests/postgres_backend_test.py338 async def test_wait_for_job_reconnects_listen_channel_after_psycopg_error(self):CODE
LOWpython/tests/postgres_backend_test.py352 async def test_wait_for_job_does_not_poll_while_blocked(self):CODE
LOWpython/tests/postgres_backend_test.py370 async def test_wait_for_job_returns_future_marker_when_only_delayed_jobs_exist(self):CODE
LOWpython/tests/postgres_backend_test.py394 async def test_extend_locks_batches_jobs_in_one_command(self):CODE
LOWpython/tests/conftest.py52def pytest_collection_modifyitems(config, items):CODE
LOW⚡python/tests/redis_connection_test.py10 def test_dict_opts_uses_single_connection(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py15 def test_url_opts_uses_single_connection(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py20 def test_caller_single_connection_client_does_not_raise(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py28 async def test_get_redis_version_returns_none_when_info_lacks_redis_version(self, _mock_load):CODE
LOWpython/tests/redis_connection_test.py47 async def test_get_redis_version_returns_string_when_info_has_redis_version(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py64 def test_returns_false_when_current_version_is_none(self):CODE
LOW⚡python/tests/redis_connection_test.py69 def test_returns_true_when_current_below_minimum(self):CODE
LOW⚡python/tests/redis_connection_test.py72 def test_returns_false_when_current_at_or_above_minimum(self):CODE
LOW⚡python/tests/redis_connection_test.py78 def test_default_skip_flags_are_false(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py83 def test_skip_flags_persist_when_set(self, _mock_load):CODE
LOW⚡python/tests/redis_connection_test.py91 async def test_skip_version_check_short_circuits_get_redis_version(self, _mock_load):CODE
LOWpython/tests/job_cancellation_test.py48 async def test_wait_resolves_after_abort(self):CODE
LOWpython/tests/job_cancellation_test.py79 async def test_processor_observes_signal_after_cancel(self):CODE
LOWpython/tests/job_cancellation_test.py130 async def test_cancel_unknown_job_returns_false(self):CODE
LOWpython/tests/job_cancellation_test.py186 async def test_processor_without_signal_param_still_works(self):CODE
LOWpython/tests/sql_loader_test.py10 def test_resolve_sql_root_uses_repo_src_postgres_in_repo_layout(self):CODE
LOWpython/tests/sql_loader_test.py25 def test_resolve_sql_root_ignores_unrelated_ancestor_src_postgres(self):CODE
LOWpython/tests/delay_test.py29 async def test_progress_delayed_job_only_after_delayed_time(self):CODE
LOWpython/tests/lock_manager_test.py44 async def test_long_running_job_survives_lock_renewal(self):CODE
LOWpython/tests/lock_manager_test.py74 async def test_locks_renewed_event_emitted(self):CODE
LOWpython/tests/lock_manager_test.py114 async def test_tracked_jobs_cleared_after_completion(self):CODE
LOWpython/tests/lock_manager_test.py144 async def test_lock_manager_closes_idempotently(self):CODE
LOWpython/tests/lock_manager_test.py159 async def test_extend_locks_does_not_pipeline_lua_scripts(self):CODE
LOW⚡python/tests/test_imports.py12 def test_unrecoverable_error_importable_from_package_root(self):CODE
LOW⚡python/tests/test_imports.py17 def test_waiting_children_error_importable_from_package_root(self):CODE
LOW⚡python/tests/test_imports.py22 def test_delayed_error_importable_from_package_root(self):CODE
LOWpython/tests/queue_test.py71 async def test_get_waiting_returns_jobs_in_ascending_order(self):CODE
LOWpython/tests/queue_test.py91 async def test_get_jobs_skips_missing_hash_and_backfills_waiting_range(self):CODE
LOWpython/tests/queue_test.py118 async def test_add_job_with_options(self):CODE
LOWpython/tests/queue_test.py147 async def test_is_paused_with_custom_prefix(self):CODE
LOWpython/tests/queue_test.py164 async def test_trim_events_manually(self):CODE
LOWpython/tests/queue_test.py182 async def test_trim_events_manually_with_custom_prefix(self):CODE
LOWpython/tests/queue_test.py277 async def test_retry_completed_jobs(self):CODE
LOWpython/tests/queue_test.py333 async def test_retry_failed_jobs_before_timestamp(self):CODE
LOWpython/tests/queue_test.py400 async def test_retry_jobs_when_queue_is_paused(self):CODE
LOWpython/tests/queue_test.py450 async def test_promote_all_delayed_jobs(self):CODE
LOWpython/tests/queue_test.py507 async def test_get_counts_per_priority(self):CODE
LOWpython/tests/queue_test.py535 async def test_obliterate_with_force_false_should_fail_with_active_jobs(self):CODE
LOWpython/tests/queue_test.py566 async def test_obliterate_with_force_true_should_succeed_with_active_jobs(self):CODE
LOWpython/tests/queue_test.py603 async def test_obliterate_with_force_true_parameter_conversion(self):CODE
LOWpython/tests/queue_test.py615 async def test_drain_count_added_unprocessed_jobs(self):CODE
150 more matches not shown…
Over-Commented Block77 hits · 76 pts
SeverityFileLineSnippetContext
LOWvitest.postgres.setup.ts41 once: () => client,COMMENT
LOWosv-scanner.toml1# OSV Scanner ConfigurationCOMMENT
LOWpython/run_tests_postgres.sh1#!/bin/bashCOMMENT
LOWpython/bullmq/scripts.py61 encoded_key = optsEncodeMap.get(key, key)COMMENT
LOWpython/bullmq/backends/postgres_backend.py261COMMENT
LOWrust/tests/queue_events_test.rs461 cleanup_queue(&queue).await;COMMENT
LOWrust/src/keys.rs41/// Validate a custom job id, mirroring `Job.validateOptions` in BullMQ Node.js.COMMENT
LOWrust/src/types.rs81impl Default for JobProgress {COMMENT
LOWrust/src/types.rs221///COMMENT
LOWrust/src/job.rs41/// A `Job` holds the data to be processed and all associated metadata.COMMENT
LOWrust/src/job.rs61 #[serde(default)]COMMENT
LOWrust/src/job.rs81 #[serde(skip_serializing_if = "Option::is_none")]COMMENT
LOWrust/src/job.rs541COMMENT
LOWrust/src/error.rs41COMMENT
LOWrust/src/error.rs61COMMENT
LOWrust/src/lib.rs1#![warn(missing_docs)]COMMENT
LOWrust/src/lib.rs21//! #[tokio::main]COMMENT
LOWrust/src/queue_events.rs1//! Cross-process queue event listener.COMMENT
LOWrust/src/queue_events.rs41use crate::error::Error;COMMENT
LOWrust/src/queue_events.rs81COMMENT
LOWrust/src/options.rs41 /// Maximum iterations before stopping.COMMENT
LOWrust/src/options.rs81 .finish()COMMENT
LOWrust/src/options.rs101 /// When a cycle is exhausted the connection stays in a failed state, butCOMMENT
LOWrust/src/options.rs141 /// Maximum number of connections in the pool.COMMENT
LOWrust/src/options.rs201 /// ```COMMENT
LOWrust/src/options.rs461 /// Custom backoff strategy function for job retries.COMMENT
LOWrust/src/options.rs541impl WorkerOptions {COMMENT
LOWrust/src/options.rs701}COMMENT
LOWrust/src/options.rs781 #[serde(skip_serializing_if = "Option::is_none")]COMMENT
LOWrust/src/options.rs801 ///COMMENT
LOWrust/src/options.rs941 /// Parent queue name.COMMENT
LOWrust/src/options.rs981 /// TTL in milliseconds for the dedup key.COMMENT
LOWrust/src/worker.rs141 /// Job progress was updated.COMMENT
LOWrust/src/worker.rs161/// use bullmq::{Worker, Job};COMMENT
LOWrust/src/worker.rs541 write_uint(buf, limit as u64).unwrap();COMMENT
LOWrust/src/flow_producer.rs41 /// Create a flow job named `name` for `queue_name` with the given `data`.COMMENT
LOWrust/src/flow_producer.rs261 }COMMENT
LOWrust/src/flow_producer.rs1001 }COMMENT
LOWrust/src/queue.rs21COMMENT
LOWrust/src/queue.rs41pub struct DependencyItem {COMMENT
LOWrust/src/queue.rs101 }COMMENT
LOWrust/src/queue.rs181 /// # async fn demo(queue: bullmq::Queue) -> bullmq::Result<()> {COMMENT
LOWrust/src/queue.rs841COMMENT
LOWrust/src/queue.rs1821 /// numeric result `1`/`0` is represented here as a `bool`:COMMENT
LOWrust/src/queue.rs2481 _ => break,COMMENT
LOWrust/src/queue.rs3021///COMMENT
LOWrust/src/redis_connection.rs281/// Grace period added on top of a blocking command's own timeout before theCOMMENT
LOWrust/src/redis_connection.rs301 /// `BZPOPMIN` after 500ms — long before a marker is written for an idleCOMMENT
LOWrust/src/job_scheduler.rs41 /// End date (Unix timestamp in ms). No executions after this.COMMENT
LOWrust/src/job_scheduler.rs61 pub name: String,COMMENT
LOWrust/src/job_scheduler.rs81 #[serde(skip_serializing_if = "Option::is_none")]COMMENT
LOWtests/telemetry_interface.test.ts441 startSpan(name: string, options?: SpanOptions, context?: any): Span {COMMENT
LOWtests/telemetry_interface.test.ts521 // Discard any spans recorded before this point (e.g. the automaticCOMMENT
LOWtests/worker.test.ts1341 expect(reconnectBlocking.callCount).toBe(2);COMMENT
LOWtests/child_stdio_null.test.ts21// Other exports are preserved from the real module in case they get pulled inCOMMENT
LOWdotnet/tests/BullMQ.Tests/AssemblyInfo.cs1using Xunit;COMMENT
LOWdotnet/scripts/test.sh1#!/usr/bin/env bashCOMMENT
LOWdotnet/src/BullMQ/Worker.cs1namespace BullMQ;COMMENT
LOWdotnet/src/BullMQ/IQueueBackend.cs1namespace BullMQ;COMMENT
LOWdotnet/src/BullMQ/IQueueBackend.cs61 /// <summary>Builds the connection client name (for discovery / observability).</summary>COMMENT
17 more matches not shown…
Empty Error Handlers12 hits · 60 pts
SeverityFileLineSnippetContext
HIGHpython/tests/job_scheduler_test.py118except asyncio.TimeoutError:CODE
HIGHpython/bullmq/worker.py238except Exception:CODE
HIGHpython/bullmq/queue_events.py192except (TypeError, ValueError):CODE
HIGHpython/bullmq/queue_events.py240except asyncio.CancelledError:CODE
HIGHpython/bullmq/queue_events.py242except Exception:CODE
HIGHpython/bullmq/lock_manager.py152except asyncio.CancelledError:CODE
HIGHpython/bullmq/lock_manager.py164except Exception:CODE
HIGHpython/bullmq/job_scheduler.py53except ValueError:CODE
HIGHpython/bullmq/backends/postgres_backend.py497except Exception:CODE
HIGHpython/bullmq/backends/postgres_connection.py266except Exception:CODE
HIGHpython/bullmq/backends/postgres_connection.py291except Exception:CODE
HIGHpython/bullmq/backends/postgres_connection.py298except Exception:CODE
Excessive Try-Catch Wrapping46 hits · 50 pts
SeverityFileLineSnippetContext
LOWpython/tests/lock_manager_test.py173 except Exception as error:CODE
MEDIUMpython/tests/worker_test.py612def on_completed(completed_job, result):CODE
MEDIUMpython/tests/worker_test.py672def on_completed(completed_job, result):CODE
LOWpython/tests/worker_test.py596 except Exception as e:CODE
LOWpython/tests/worker_test.py618 except Exception as e:CODE
LOWpython/tests/worker_test.py656 except Exception as e:CODE
LOWpython/tests/worker_test.py679 except Exception as e:CODE
LOWpython/tests/worker_test.py722 except Exception as e:CODE
LOWpython/tests/worker_test.py747 except Exception as e:CODE
LOWpython/tests/worker_test.py787 except Exception as e:CODE
LOWpython/tests/worker_test.py813 except Exception as e:CODE
LOWpython/bullmq/queue.py202 except Exception as err:CODE
LOWpython/bullmq/worker.py215 except Exception as e:CODE
LOWpython/bullmq/worker.py238 except Exception:CODE
LOWpython/bullmq/worker.py326 except Exception as err:CODE
LOWpython/bullmq/worker.py366 except Exception as err:CODE
LOWpython/bullmq/worker.py460 except Exception as err:CODE
LOWpython/bullmq/worker.py466 except Exception as err:CODE
LOWpython/bullmq/worker.py491 except Exception as err:CODE
LOWpython/bullmq/worker.py589 except Exception as e:CODE
LOWpython/bullmq/worker.py597 except Exception as e:CODE
LOWpython/bullmq/worker.py627 except Exception as err:CODE
MEDIUMpython/bullmq/worker.py591def runStalledJobsCheck(self):CODE
LOWpython/bullmq/queue_events.py107 except Exception as err:CODE
LOWpython/bullmq/queue_events.py159 except Exception as err:CODE
LOWpython/bullmq/queue_events.py242 except Exception:CODE
MEDIUMpython/bullmq/queue_events.py102def _autorun(self) -> None:CODE
LOWpython/bullmq/lock_manager.py157 except Exception as err:CODE
LOWpython/bullmq/lock_manager.py164 except Exception:CODE
LOWpython/bullmq/lock_manager.py241 except Exception as err:CODE
LOWpython/bullmq/timer.py22 except Exception as err:CODE
MEDIUMpython/bullmq/timer.py17def _job(self) -> None:CODE
LOWpython/bullmq/job.py390 except Exception as err:CODE
LOWpython/bullmq/utils.py20 except Exception as e:CODE
LOWpython/bullmq/utils.py54 except Exception:CODE
LOW⚡python/bullmq/utils.py71 except Exception:CODE
LOW⚡python/bullmq/utils.py78 except Exception:CODE
LOW⚡python/bullmq/utils.py84 except Exception:CODE
MEDIUMpython/bullmq/utils.py17def extract_result(job_task, emit_callback):CODE
LOWpython/bullmq/backends/postgres_backend.py497 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py266 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py291 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py298 except Exception:CODE
LOWpython/bullmq/backends/redis_backend.py100 except Exception as err:CODE
LOWpython/bullmq/backends/redis_backend.py106 except Exception as err:CODE
LOWdocs/gitbook/guide/jobs/retrying-job.md247except Exception as error:CODE
Unused Imports52 hits · 49 pts
SeverityFileLineSnippetContext
LOWpython/tests/lock_manager_test.py21CODE
LOWpython/bullmq/queue_events.py24CODE
LOWpython/bullmq/lock_manager.py20CODE
LOWpython/bullmq/lock_manager.py29CODE
LOWpython/bullmq/backend.py24CODE
LOWpython/bullmq/backend.py30CODE
LOWpython/bullmq/job.py1CODE
LOWpython/bullmq/abort_controller.py34CODE
LOWpython/bullmq/__init__.py10CODE
LOWpython/bullmq/__init__.py11CODE
LOWpython/bullmq/__init__.py12CODE
LOWpython/bullmq/__init__.py13CODE
LOWpython/bullmq/__init__.py14CODE
LOWpython/bullmq/__init__.py15CODE
LOWpython/bullmq/__init__.py16CODE
LOWpython/bullmq/__init__.py16CODE
LOWpython/bullmq/__init__.py16CODE
LOWpython/bullmq/__init__.py17CODE
LOWpython/bullmq/__init__.py18CODE
LOWpython/bullmq/__init__.py19CODE
LOWpython/bullmq/__init__.py19CODE
LOWpython/bullmq/__init__.py19CODE
LOWpython/bullmq/job_scheduler.py24CODE
LOWpython/bullmq/job_scheduler.py30CODE
LOWpython/bullmq/job_scheduler.py32CODE
LOWpython/bullmq/job_scheduler.py32CODE
LOWpython/bullmq/job_scheduler.py38CODE
LOWpython/bullmq/queue_events_producer.py10CODE
LOWpython/bullmq/scripts.py6CODE
LOWpython/bullmq/custom_errors/__init__.py1CODE
LOWpython/bullmq/custom_errors/__init__.py2CODE
LOWpython/bullmq/custom_errors/__init__.py3CODE
LOWpython/bullmq/types/__init__.py1CODE
LOWpython/bullmq/types/__init__.py2CODE
LOWpython/bullmq/types/__init__.py3CODE
LOWpython/bullmq/types/__init__.py4CODE
LOWpython/bullmq/types/__init__.py5CODE
LOWpython/bullmq/types/__init__.py6CODE
LOWpython/bullmq/types/__init__.py6CODE
LOWpython/bullmq/types/__init__.py7CODE
LOWpython/bullmq/types/__init__.py8CODE
LOWpython/bullmq/types/__init__.py9CODE
LOWpython/bullmq/types/__init__.py10CODE
LOWpython/bullmq/types/__init__.py10CODE
LOWpython/bullmq/types/__init__.py10CODE
LOWpython/bullmq/backends/postgres_backend.py16CODE
LOWpython/bullmq/backends/postgres_backend.py31CODE
LOWpython/bullmq/backends/postgres_connection.py15CODE
LOWpython/bullmq/backends/__init__.py1CODE
LOWpython/bullmq/backends/redis_backend.py17CODE
LOWpython/bullmq/backends/redis_backend.py32CODE
LOWpython/bullmq/postgres/sql_loader.py16CODE
Redundant / Tautological Comments13 hits · 20 pts
SeverityFileLineSnippetContext
LOWpython/bullmq/worker.py492 # Check if this is a connection error that should be retriedCOMMENT
LOW.github/workflows/release.yml48 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml69 # Check if there are actually changes to commit after addingCOMMENT
LOW.github/workflows/release.yml150 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml170 # Check if there are actually changes to commit after addingCOMMENT
LOW.github/workflows/release.yml241 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml260 # Check if there are actually changes to commit after addingCOMMENT
LOW.github/workflows/release.yml342 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml361 # Check if there are actually changes to commit after addingCOMMENT
LOW.github/workflows/release.yml428 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml448 # Check if there are actually changes to commit after addingCOMMENT
LOW.github/workflows/release.yml518 # Check if there are any changes to commitCOMMENT
LOW.github/workflows/release.yml538 # Check if there are actually changes to commit after addingCOMMENT
Fake / Example Data17 hits · 17 pts
SeverityFileLineSnippetContext
LOWelixir/README.md64BullMQ.Queue.add("emails", "send", %{to: "user@example.com"},CODE
LOWelixir/README.md99 BullMQ.Queue.add("emails", "send-welcome", %{to: "user@example.com"},CODE
LOWelixir/README.md120 to: "user@example.com",CODE
LOWelixir/guides/flows.md214 data: %{recipients: ["admin@example.com"]},CODE
LOWelixir/guides/workers.md457{:ok, job} = BullMQ.Queue.add("emails", "send", %{to: "user@example.com"},CODE
LOWelixir/guides/introduction.md37 to: "user@example.com",CODE
LOWelixir/guides/deduplication.md33BullMQ.Queue.add("notifications", "send-email", %{to: "user@example.com"},CODE
LOWelixir/guides/deduplication.md39BullMQ.Queue.add("notifications", "send-email", %{to: "user@example.com"},CODE
LOWrust/README.md52 "to": "user@example.com",CODE
LOWrust/tests/job_scheduler_test.rs115 let data = serde_json::json!({"email": "user@example.com"});CODE
LOWtests/obliterate.test.ts90 return job.log('Lorem Ipsum Dolor Sit Amet');CODE
LOWtests/obliterate.test.ts90 return job.log('Lorem Ipsum Dolor Sit Amet');CODE
LOWdocs/gitbook/elixir/introduction.md72 to: "user@example.com",CODE
LOWphp/README.md100 'to' => 'user@example.com',CODE
LOWphp/src/Queue.php109 * $job = $queue->add('email', ['to' => 'user@example.com']);COMMENT
LOWdotnet/README.md42await queue.AddAsync("welcome", new { to = "user@example.com" });CODE
LOWdotnet/README.md90await queue.AddAsync("welcome", new { to = "user@example.com" });CODE
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHpython/bullmq/types/queue_options.py0avoid version validation to be greater or equal than v5.0.0. @default falseSTRING
HIGHpython/bullmq/types/worker_options.py0avoid version validation to be greater or equal than v5.0.0. @default falseSTRING
HIGHpython/bullmq/types/queue_events_options.py0avoid version validation to be greater or equal than v5.0.0. @default falseSTRING
Deep Nesting13 hits · 11 pts
SeverityFileLineSnippetContext
LOWpython/tests/worker_test.py229CODE
LOWpython/tests/worker_test.py416CODE
LOWpython/tests/worker_test.py429CODE
LOWpython/bullmq/queue.py223CODE
LOWpython/bullmq/queue.py437CODE
LOWpython/bullmq/worker.py162CODE
LOWpython/bullmq/worker.py472CODE
LOWpython/bullmq/worker.py644CODE
LOWpython/bullmq/lock_manager.py168CODE
LOWpython/bullmq/job_scheduler.py346CODE
LOWpython/bullmq/scripts.py197CODE
LOWpython/bullmq/scripts.py835CODE
LOWpython/bullmq/backends/postgres_backend.py774CODE
Self-Referential Comments3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUMpython/tests/queue_test.py543 # Create a worker that processes jobs slowlyCOMMENT
MEDIUMpython/tests/queue_test.py575 # Create a worker that processes jobs slowlyCOMMENT
MEDIUM.github/workflows/release.yml318 # Create a clean directory with only the necessary filesCOMMENT
AI Slop Vocabulary3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUMrust/src/lib.rs5//! A powerful, fast, and robust job queue backed by Redis.COMMENT
MEDIUMtests/stalled_jobs.test.ts1111 // Wait for both failures so the test is robust to event ordering andCOMMENT
MEDIUMsrc/classes/redis-queue-backend.ts2807 // To make this robust we race the blocking command against a watchdogCOMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHrust/src/flow_producer.rs269 /// The returned [`JobNode`] keeps the same tree shape as requested. TheCOMMENT
Modern Structural Boilerplate5 hits · 6 pts
SeverityFileLineSnippetContext
LOWpython/bullmq/redis_connection.py164 async def set_client_name(self, name: str) -> None:CODE
LOW⚡python/bullmq/redis_connection.py180 async def _set_client_name_on_client(self, client, name: str) -> None:CODE
LOW⚡python/bullmq/redis_connection.py186 def _set_client_name_on_pool(self, client, name: str) -> None:CODE
LOWpython/bullmq/backends/postgres_connection.py271 async def set_application_name(self, name: str) -> None:CODE
LOWpython/bullmq/backends/__init__.py3__all__ = [CODE
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHpython/bullmq/job.py108 Attempts to retry the job. Only a job that has failed or completed can be retried. Args: sSTRING
Verbosity Indicators3 hits · 4 pts
SeverityFileLineSnippetContext
LOWrust/tests/worker_test.rs9901 // Step 1: completeCOMMENT
LOWrust/tests/flow_test.rs4454 // Step 0: Add a child dynamicallyCOMMENT
LOWrust/tests/flow_test.rs4492 // Step 1: Children are done, completeCOMMENT
Structural Annotation Overuse3 hits · 4 pts
SeverityFileLineSnippetContext
LOWrust/tests/worker_test.rs9901 // Step 1: completeCOMMENT
LOWrust/tests/flow_test.rs4454 // Step 0: Add a child dynamicallyCOMMENT
LOWrust/tests/flow_test.rs4492 // Step 1: Children are done, completeCOMMENT
AI Structural Patterns3 hits · 3 pts
SeverityFileLineSnippetContext
LOWpython/bullmq/scripts.py543CODE
LOWpython/bullmq/scripts.py671CODE
LOWpython/bullmq/scripts.py680CODE
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUM.github/workflows/codeql.yml58 # If you are analyzing a compiled language, you can modify the 'build-mode' for that language to customize howCOMMENT
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippetContext
LOWdotnet/scripts/test.sh10# Usage:COMMENT