Repository Analysis

taskforcesh/bullmq

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

8.1 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of taskforcesh/bullmq, a TypeScript project with 9,344 GitHub stars. SynthScan v2.0 examined 175,380 lines of code across 754 source files, recording 872 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 8.1 places this repository in the Low AI signal band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

8.1
Adjusted Score
8.1
Raw Score
100%
Time Factor
2026-08-28
Last Push
9.3K
Stars
TypeScript
Language
175.4K
Lines of Code
754
Files
872
Pattern Hits
2026-08-29
Scan Date
0.01
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 0HIGH 5MEDIUM 464LOW 403

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 872 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Decorative Section Separators450 hits · 936 pts
SeverityFileLineSnippetContext
MEDIUMpython/bullmq/backend.py328 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py330 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py340 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py342 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py351 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py353 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py41 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py43 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py81 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py83 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py103 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py105 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py131 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py133 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py203 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py205 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py240 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py242 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py254 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py256 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py276 # ============================================================COMMENT
MEDIUMpython/bullmq/backend.py278 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py725 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py727 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py735 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py737 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py236 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py238 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py266 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py268 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py284 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py286 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py376 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py378 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py548 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py550 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py590 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py592 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py606 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py608 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py632 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py634 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py798 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/postgres_backend.py800 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py405 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py407 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py417 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py419 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py424 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py426 # ============================================================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
MEDIUMpython/bullmq/backends/redis_backend.py197 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py199 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py265 # ============================================================COMMENT
MEDIUMpython/bullmq/backends/redis_backend.py267 # ============================================================COMMENT
390 more matches not shown…
Hyper-Verbose Identifiers191 hits · 201 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.py20 def test_row_to_job_map_json_encodes_plain_strings(self):CODE
LOWpython/tests/postgres_backend_test.py41 def test_job_from_json_round_trips_plain_string_fields(self):CODE
LOWpython/tests/postgres_backend_test.py64 def test_client_name_includes_schema_namespace(self):CODE
LOWpython/tests/postgres_backend_test.py73 async def test_move_to_failed_keeps_failed_reason_as_raw_text(self):CODE
LOWpython/tests/postgres_backend_test.py143 async def test_returns_last_applied_migration_version(self):CODE
LOWpython/tests/postgres_backend_test.py161 def test_quote_schema_name_error_message_mentions_dollar_signs(self):CODE
LOWpython/tests/postgres_backend_test.py168 async def test_ensure_job_channel_listens_once_per_connection(self):CODE
LOWpython/tests/postgres_backend_test.py182 async def test_ensure_job_channel_relistens_after_reconnect(self):CODE
LOWpython/tests/postgres_backend_test.py200 async def test_reset_job_channel_forces_new_listen_connection(self):CODE
LOWpython/tests/postgres_backend_test.py218 async def test_listen_connection_applies_last_application_name_when_created(self):CODE
LOWpython/tests/postgres_backend_test.py248 async def test_set_application_name_updates_existing_listen_connection(self):CODE
LOWpython/tests/postgres_backend_test.py316 async def test_wait_for_job_reconnects_listen_channel_after_psycopg_error(self):CODE
LOWpython/tests/postgres_backend_test.py328 async def test_wait_for_job_returns_future_marker_when_only_delayed_jobs_exist(self):CODE
LOWpython/tests/postgres_backend_test.py352 async def test_extend_locks_batches_jobs_in_one_command(self):CODE
LOWpython/tests/conftest.py52def pytest_collection_modifyitems(config, items):CODE
LOWpython/tests/redis_connection_test.py10 def test_dict_opts_uses_single_connection(self, _mock_load):CODE
LOWpython/tests/redis_connection_test.py15 def test_url_opts_uses_single_connection(self, _mock_load):CODE
LOWpython/tests/redis_connection_test.py20 def test_caller_single_connection_client_does_not_raise(self, _mock_load):CODE
LOWpython/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
LOWpython/tests/redis_connection_test.py64 def test_returns_false_when_current_version_is_none(self):CODE
LOWpython/tests/redis_connection_test.py69 def test_returns_true_when_current_below_minimum(self):CODE
LOWpython/tests/redis_connection_test.py72 def test_returns_false_when_current_at_or_above_minimum(self):CODE
LOWpython/tests/redis_connection_test.py78 def test_default_skip_flags_are_false(self, _mock_load):CODE
LOWpython/tests/redis_connection_test.py83 def test_skip_flags_persist_when_set(self, _mock_load):CODE
LOWpython/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.py38 async def test_long_running_job_survives_lock_renewal(self):CODE
LOWpython/tests/lock_manager_test.py68 async def test_locks_renewed_event_emitted(self):CODE
LOWpython/tests/lock_manager_test.py108 async def test_tracked_jobs_cleared_after_completion(self):CODE
LOWpython/tests/lock_manager_test.py138 async def test_lock_manager_closes_idempotently(self):CODE
LOWpython/tests/test_imports.py12 def test_unrecoverable_error_importable_from_package_root(self):CODE
LOWpython/tests/test_imports.py17 def test_waiting_children_error_importable_from_package_root(self):CODE
LOWpython/tests/test_imports.py22 def test_delayed_error_importable_from_package_root(self):CODE
LOWpython/tests/queue_test.py53 async def test_get_waiting_returns_jobs_in_ascending_order(self):CODE
LOWpython/tests/queue_test.py73 async def test_get_jobs_skips_missing_hash_and_backfills_waiting_range(self):CODE
LOWpython/tests/queue_test.py100 async def test_add_job_with_options(self):CODE
LOWpython/tests/queue_test.py129 async def test_is_paused_with_custom_prefix(self):CODE
LOWpython/tests/queue_test.py146 async def test_trim_events_manually(self):CODE
LOWpython/tests/queue_test.py164 async def test_trim_events_manually_with_custom_prefix(self):CODE
LOWpython/tests/queue_test.py259 async def test_retry_completed_jobs(self):CODE
LOWpython/tests/queue_test.py315 async def test_retry_failed_jobs_before_timestamp(self):CODE
LOWpython/tests/queue_test.py382 async def test_retry_jobs_when_queue_is_paused(self):CODE
LOWpython/tests/queue_test.py432 async def test_promote_all_delayed_jobs(self):CODE
LOWpython/tests/queue_test.py489 async def test_get_counts_per_priority(self):CODE
LOWpython/tests/queue_test.py517 async def test_obliterate_with_force_false_should_fail_with_active_jobs(self):CODE
LOWpython/tests/queue_test.py548 async def test_obliterate_with_force_true_should_succeed_with_active_jobs(self):CODE
LOWpython/tests/queue_test.py585 async def test_obliterate_with_force_true_parameter_conversion(self):CODE
LOWpython/tests/queue_test.py597 async def test_drain_count_added_unprocessed_jobs(self):CODE
LOWpython/tests/queue_test.py690 async def test_get_prioritized_jobs(self):CODE
LOWpython/tests/queue_test.py731 async def test_get_failed_returns_only_failed_jobs(self):CODE
LOWpython/tests/queue_events_test.py26 async def test_emits_added_event_with_job_id(self):CODE
131 more matches not shown…
Over-Commented Block64 hits · 64 pts
SeverityFileLineSnippetContext
LOWvitest.postgres.setup.ts41 once: () => client,COMMENT
LOWosv-scanner.toml1# OSV Scanner ConfigurationCOMMENT
LOWvitest.config.ts41COMMENT
LOWpython/run_tests_postgres.sh1#!/bin/bashCOMMENT
LOWpython/bullmq/scripts.py61 encoded_key = optsEncodeMap.get(key, key)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.rs81pub struct QueueEventEntry {COMMENT
LOWrust/src/options.rs41 /// Maximum iterations before stopping.COMMENT
LOWrust/src/options.rs81 .finish()COMMENT
LOWrust/src/options.rs341 pub backoff_strategy: Option<BackoffStrategyFn>,COMMENT
LOWrust/src/options.rs421 /// Create default worker options.COMMENT
LOWrust/src/options.rs581COMMENT
LOWrust/src/options.rs621COMMENT
LOWrust/src/options.rs661 pub remove_dependency_on_failure: Option<bool>,COMMENT
LOWrust/src/options.rs681 /// ```COMMENT
LOWrust/src/options.rs821 pub queue: String,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.rs261COMMENT
LOWrust/src/flow_producer.rs281 self.add_with_opts(flow, &FlowOptions::default()).awaitCOMMENT
LOWrust/src/flow_producer.rs1041 }COMMENT
LOWrust/src/queue.rs121COMMENT
LOWrust/src/queue.rs1241COMMENT
LOWrust/src/queue.rs1641 ///COMMENT
LOWrust/src/queue.rs2301 }COMMENT
LOWrust/src/queue.rs2801 }COMMENT
LOWrust/src/redis_connection.rs141 /// The connection is created with its response timeout **disabled**.COMMENT
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/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
LOWdotnet/src/BullMQ/IQueueBackend.cs281 /// <summary>COMMENT
LOWdotnet/src/BullMQ/PostgresBackend.cs1using System.Text.Json;COMMENT
LOWdotnet/src/BullMQ/PostgresBackend.cs781 return dd <= 0 ? new MarkerResult(Name, 0) : new MarkerResult(Name, NowMs() + dd);COMMENT
LOWdotnet/src/BullMQ/Redis/LuaScripts.cs1using System.Reflection;COMMENT
LOWdotnet/src/BullMQ/Serialization/MsgPack.cs1using System.Buffers.Binary;COMMENT
LOW.github/workflows/codeql-analysis.yml1# For most projects, this workflow file will not need changing; you simply needCOMMENT
LOW.github/workflows/codeql-analysis.yml61 # ✏️ If the Autobuild fails above, remove it and uncomment the following three linesCOMMENT
LOW.github/workflows/test.yml461 # continue-on-error: trueCOMMENT
LOW.github/workflows/codeql.yml1# For most projects, this workflow file will not need changing; you simply needCOMMENT
LOWsrc/classes/redis-queue-backend.ts2741 // rejection must not surface as an unhandled promise rejection.COMMENT
LOWsrc/classes/redis-queue-backend.ts2821 // If the watchdog abandons this command below, its (possibly much later)COMMENT
LOWsrc/classes/bun-redis-client.ts541 }COMMENT
4 more matches not shown…
Excessive Try-Catch Wrapping45 hits · 50 pts
SeverityFileLineSnippetContext
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.py206 except Exception as e:CODE
LOWpython/bullmq/worker.py219 except Exception:CODE
LOWpython/bullmq/worker.py302 except Exception as err:CODE
LOWpython/bullmq/worker.py342 except Exception as err:CODE
LOWpython/bullmq/worker.py424 except Exception as err:CODE
LOWpython/bullmq/worker.py430 except Exception as err:CODE
LOWpython/bullmq/worker.py455 except Exception as err:CODE
LOWpython/bullmq/worker.py553 except Exception as e:CODE
LOWpython/bullmq/worker.py561 except Exception as e:CODE
LOWpython/bullmq/worker.py587 except Exception as err:CODE
MEDIUMpython/bullmq/worker.py555def 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
LOWpython/bullmq/utils.py71 except Exception:CODE
LOWpython/bullmq/utils.py78 except Exception:CODE
LOWpython/bullmq/utils.py84 except Exception:CODE
MEDIUMpython/bullmq/utils.py17def extract_result(job_task, emit_callback):CODE
LOWpython/bullmq/backends/postgres_backend.py484 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py248 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py273 except Exception:CODE
LOWpython/bullmq/backends/postgres_connection.py280 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.py20CODE
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.py456 # 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
AI Slop Vocabulary4 hits · 10 pts
SeverityFileLineSnippetContext
MEDIUMpython/bullmq/backends/postgres_backend.py771 # claimable-job probe is a robust fallback (delivery of a NOTIFY thatCOMMENT
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.ts2752 // To make this robust we race the blocking command against a watchdogCOMMENT
Deep Nesting12 hits · 10 pts
SeverityFileLineSnippetContext
LOWpython/tests/worker_test.py229CODE
LOWpython/tests/worker_test.py416CODE
LOWpython/tests/worker_test.py429CODE
LOWpython/bullmq/queue.py223CODE
LOWpython/bullmq/queue.py420CODE
LOWpython/bullmq/worker.py158CODE
LOWpython/bullmq/worker.py436CODE
LOWpython/bullmq/lock_manager.py168CODE
LOWpython/bullmq/job_scheduler.py346CODE
LOWpython/bullmq/scripts.py197CODE
LOWpython/bullmq/scripts.py837CODE
LOWpython/bullmq/backends/postgres_backend.py748CODE
Self-Referential Comments3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUMpython/tests/queue_test.py525 # Create a worker that processes jobs slowlyCOMMENT
MEDIUMpython/tests/queue_test.py557 # Create a worker that processes jobs slowlyCOMMENT
MEDIUM.github/workflows/release.yml318 # Create a clean directory with only the necessary filesCOMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHrust/src/flow_producer.rs273 /// 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
LOWpython/bullmq/redis_connection.py180 async def _set_client_name_on_client(self, client, name: str) -> None:CODE
LOWpython/bullmq/redis_connection.py186 def _set_client_name_on_pool(self, client, name: str) -> None:CODE
LOWpython/bullmq/backends/postgres_connection.py253 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.rs9827 // 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.rs9827 // 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.py544CODE
LOWpython/bullmq/scripts.py673CODE
LOWpython/bullmq/scripts.py682CODE
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