Home / celery / celery
AI Slop Code RIsk Monitor

celery/celery

Distributed Task Queue (development branch)

32.8 High pattern signal View on GitHub

Maintenance and Governance Review

This report summarizes scanner evidence for celery/celery, a Python project with 28,939 GitHub stars. SynthScan examined 126,938 lines of code across 551 source files, recording 3458 pattern matches distributed across 22 syntactic categories. The legacy adjusted pattern signal is 32.8 (High 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.

32.8
Adjusted Signal
32.8
Raw Pattern Score
100%
Time Factor
2026-10-10
Last Push
28.9K
Stars
Python
Language
126.9K
Lines of Code
551
Files
3.5K
Pattern Hits
2026-10-12
Scan Date
0.38
HC Hit Rate

Risk Review · v3

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

Cognitive Ownership Risk 62.8/100 · HIGH

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

Hallucinated Dependency & Supply Chain Risk 17.9/100 · LOW

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

Agent Over-Engineering Ratio 74.3/100 · HIGH

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

PR Review Velocity Impact 84.4/100 · CRITICAL

Which changes need focused human review? 3458 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 19HIGH 191MEDIUM 64LOW 3184

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 3458 distinct pattern matches across 22 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.

Hyper-Verbose Identifiers2627 hits · 2242 pts
SeverityFileLineSnippetContext
LOWdocs/conf.py90def configcheck_project_settings():CODE
LOWdocs/conf.py103def configcheck_should_ignore(setting):CODE
LOWdocs/_ext/celerydocs.py127def maybe_resolve_abbreviations(app, env, node, contnode):CODE
LOWt/smoke/signals.py13def worker_process_init_handler(sender, **kwargs):CODE
LOWt/smoke/signals.py18def worker_process_shutdown_handler(sender, pid, exitcode, **kwargs):CODE
LOWt/smoke/tasks.py23def add_with_explicit_lazy_option(x, y):CODE
LOWt/smoke/tasks.py47def soft_time_limit_lower_than_time_limit():CODE
LOWt/smoke/tasks.py52def soft_time_limit_must_exceed_time_limit():CODE
LOW⚡t/smoke/tasks.py70def self_termination_system_exit():CODE
LOW⚡t/smoke/tasks.py76def countdown_task_with_retry(self):CODE
LOW⚡t/smoke/tasks.py84def non_eta_task_with_retries(self):CODE
LOWt/smoke/tasks.py98def self_termination_delay_timeout():CODE
LOWt/smoke/tasks.py104def self_termination_exhaust_memory():CODE
LOWt/smoke/tests/test_revoked_sync.py42 def test_received_ids_are_stamped_locally(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_revoked_sync.py98 def test_sync_with_another_version(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_redis_backend_reentrant.py155 def test_results_collected_during_pubsub_calls(self, celery_setup: CeleryTestSetup, concurrency: str):STRING
LOWt/smoke/tests/test_gossip.py20 def test_worker_event_across_timezones_causes_no_drift_warning(CODE
LOWt/smoke/tests/test_signals.py45 def before_task_publish_handler(*args, **kwargs):CODE
LOWt/smoke/tests/test_signals.py57 def after_task_publish_handler(*args, **kwargs):CODE
LOW⚡t/smoke/tests/test_beat_remote_control.py41 def test_answers_ping_like_a_worker(CODE
LOW⚡t/smoke/tests/test_beat_remote_control.py48 def test_coexists_with_a_worker_on_the_exchange(CODE
LOW⚡t/smoke/tests/test_beat_remote_control.py57 def test_ignores_worker_only_commands(CODE
LOW⚡t/smoke/tests/test_beat_remote_control.py66 def test_stops_replying_once_the_scheduler_stalls(CODE
LOWt/smoke/tests/test_rpc_backend.py23def default_rabbitmq_broker_image() -> str:CODE
LOWt/smoke/tests/test_rpc_backend.py28def default_rabbitmq_broker_ports() -> dict:CODE
LOWt/smoke/tests/test_rpc_backend.py85 def test_repeated_final_polls_do_not_recirculate(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_task_queue_max_priority.py25 def test_messages_are_delivered_in_priority_order(CODE
LOWt/smoke/tests/test_concurrency_auto.py69def default_worker_container_cls() -> type[CeleryWorkerContainer]:CODE
LOWt/smoke/tests/test_concurrency_auto.py74def default_worker_container_session_cls() -> type[CeleryWorkerContainer]:CODE
LOWt/smoke/tests/test_concurrency_auto.py109 def test_pool_size_matches_cgroup_quota(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py132 def test_fractional_quota_rounds_up_to_one(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py154 def test_no_quota_falls_back_to_host_cpu_count(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py181 def test_cpuset_caps_pool_size(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py200 def test_threads_pool_ignores_quota(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py238 def test_default_ignores_cgroup_quota(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_concurrency_auto.py256 def test_explicit_int_overrides_quota(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_control.py23 def test_shutdown_exit_with_zero(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_control.py35 def test_report_with_multiserver_result_backend(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_control.py74 def test_add_then_cancel_consumer_preserves_order(CODE
LOWt/smoke/tests/test_control.py94 def wait_until_pending_operations_are_drained() -> None:CODE
LOWt/smoke/tests/test_control.py124 def test_chord_completes_when_reserved_member_is_revoked(CODE
LOWt/smoke/tests/test_canvas.py38 def test_chain_gets_last_task_id_with_failing_tasks_in_chain(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_canvas.py56 def test_upgrade_to_chord_inside_chains(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_canvas.py70 def test_chain_of_implicit_chords_runs_each_step_once_in_order(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_canvas.py94 def test_chain_skips_empty_group_on_worker(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_canvas.py179 def test_chord_error_propagation_with_different_body_types(CODE
LOWt/smoke/tests/test_canvas.py220 def test_pending_tasks_released_on_forget(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_memcached_backend.py42 def test_too_large_result_is_not_silently_dropped(self, celery_setup: CeleryTestSetup):CODE
LOW⚡t/smoke/tests/test_worker.py41 def test_tasks_run_in_spawned_children(self, celery_setup: CeleryTestSetup):CODE
LOW⚡t/smoke/tests/test_worker.py47 def test_child_is_replaced_after_hard_time_limit(self, celery_setup: CeleryTestSetup):CODE
LOW⚡t/smoke/tests/test_worker.py55 def test_spawn_worker_executes_task_with_explicit_lazy_option(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py73 def test_restart_during_task_execution(CODE
LOWt/smoke/tests/test_worker.py84 def test_restart_between_task_execution(CODE
LOWt/smoke/tests/test_worker.py122 def test_multiple_warm_shutdown_does_nothing(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py151 def test_hard_shutdown_from_warm(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py167 def test_hard_shutdown_from_cold(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py198 def test_shutdown_with_long_running_tasks(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py235 def test_hard_shutdown_from_cold(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py274 def test_hard_shutdown_from_soft(self, celery_setup: CeleryTestSetup):CODE
LOWt/smoke/tests/test_worker.py289 def test_task_completes_during_soft_shutdown(self, celery_setup: CeleryTestSetup):CODE
2567 more matches not shown…
Empty Error Handlers173 hits · 865 pts
SeverityFileLineSnippetContext
HIGHdocs/conf.py99except KeyError:CODE
HIGHdocs/_ext/celerydocs.py93except AttributeError:CODE
HIGHdocs/_ext/celerydocs.py75except KeyError:CODE
HIGHdocs/_ext/celerydocs.py84except KeyError:CODE
HIGHt/unit/conftest.py312except ImportError:CODE
HIGHt/unit/conftest.py322except OSError:CODE
HIGHt/unit/conftest.py450except AttributeError:CODE
HIGHt/unit/conftest.py559except KeyError:CODE
HIGHt/unit/conftest.py358except ImportError:CODE
HIGHt/unit/conftest.py460except AttributeError:CODE
HIGHt/unit/conftest.py572except KeyError:CODE
HIGHt/unit/tasks/test_chord.py188except Retry:CODE
HIGHt/unit/tasks/test_tasks.py1880except Retry:CODE
HIGHt/unit/tasks/test_tasks.py481except AttributeError:CODE
HIGHt/unit/app/test_amqp.py31except AttributeError:CODE
HIGHt/unit/app/test_amqp.py49except AttributeError:CODE
HIGHt/unit/app/test_loaders.py184except ValueError:CODE
HIGHt/unit/app/test_beat.py117except TypeError:CODE
HIGHt/unit/security/test_security.py41except SerializerNotInstalled:CODE
HIGHt/unit/backends/test_asynchronous.py568except Exception:CODE
HIGHt/unit/utils/test_platforms.py99except OSError:CODE
HIGHt/unit/utils/test_platforms.py121except OSError:CODE
HIGHt/unit/utils/test_platforms.py544except AttributeError:CODE
HIGHt/unit/concurrency/test_eventlet.py33except KeyError:CODE
HIGHt/unit/concurrency/test_prefork.py98except OSError:CODE
HIGHt/unit/worker/test_native_delayed_delivery.py193except StopIteration:CODE
HIGHt/unit/worker/test_native_delayed_delivery.py216except ConnectionRefusedError:CODE
HIGHt/unit/worker/test_request.py1546except AttributeError:CODE
HIGHt/unit/worker/test_worker.py561except RuntimeError:CODE
HIGHt/unit/apps/test_multi.py442except AssertionError:CODE
HIGHt/integration/conftest.py96except OSError:CODE
HIGHt/integration/test_mem_leak_in_exception_handling.py113except Exception:CODE
HIGHt/integration/test_mem_leak_in_exception_handling.py136except Exception:CODE
HIGHt/integration/test_mem_leak_in_exception_handling.py189except Exception:CODE
HIGHt/integration/test_mem_leak_in_exception_handling.py230except Exception:CODE
HIGHt/integration/test_tasks.py40except RuntimeError:CODE
HIGHt/integration/test_connection_recovery.py174except Exception:CODE
HIGHt/benchmarks/bench_worker.py102except IndexError:CODE
HIGHcelery/bootsteps.py183except IGNORE_ERRORS:CODE
HIGHcelery/platforms.py111except AttributeError:CODE
HIGHcelery/platforms.py554except Exception: # pylint: disable=broad-exceptCODE
HIGHcelery/platforms.py749except (AttributeError, ValueError):CODE
HIGHcelery/platforms.py782except OSError:CODE
HIGHcelery/platforms.py236except AttributeError: # pragma: no coverCODE
HIGHcelery/local.py338except AttributeError:CODE
HIGHcelery/local.py333except AttributeError: # pragma: no coverCODE
HIGHcelery/local.py348except AttributeError: # pragma: no coverCODE
HIGHcelery/__init__.py135except KeyError:CODE
HIGHcelery/__init__.py140except KeyError:CODE
HIGHcelery/result.py635except KeyError:CODE
HIGHcelery/result.py915except IndexError:CODE
HIGHcelery/beat.py936except socket.timeout:CODE
HIGHcelery/canvas.py2444except (AttributeError, KeyError):CODE
HIGHcelery/canvas.py1414except (LookupError, AttributeError):CODE
HIGHcelery/canvas.py2082except LookupError:CODE
HIGHcelery/app/amqp.py534except AttributeError:CODE
HIGHcelery/app/trace.py838except AttributeError:CODE
HIGHcelery/app/trace.py842except KeyError:CODE
HIGHcelery/app/trace.py338except RuntimeError:CODE
HIGHcelery/app/trace.py517except BackendGetMetaError:CODE
113 more matches not shown…
Hallucination Indicators19 hits · 250 pts
SeverityFileLineSnippetContext
CRITICAL⚡t/unit/tasks/test_canvas.py366 x.type.app.control.election.assert_called()CODE
CRITICALt/unit/app/test_app.py2000 self.app.amqp.queues.select.assert_called_with({'foo', 'bar'})CODE
CRITICAL⚡t/unit/backends/test_redis.py223 consumer.backend.client.connection_pool.reset.assert_called_once()CODE
CRITICAL⚡t/unit/backends/test_redis.py229 consumer.backend.client.connection_pool.reset.reset_mock()CODE
CRITICAL⚡t/unit/backends/test_redis.py232 consumer.backend.client.connection_pool.reset.assert_called_once()CODE
CRITICAL⚡t/unit/backends/test_redis.py238 consumer.backend.client.connection_pool.reset.reset_mock()CODE
CRITICAL⚡t/unit/backends/test_redis.py2363 self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(CODE
CRITICAL⚡t/unit/backends/test_redis.py2375 self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(CODE
CRITICAL⚡t/unit/backends/test_redis.py2391 self.b.client.pipeline.return_value.rpush().llen().get().get().expire(CODE
CRITICAL⚡t/unit/backends/test_redis.py2407 self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(CODE
CRITICALt/unit/backends/test_redis.py2331 self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(CODE
CRITICALt/unit/backends/test_redis.py2347 self.b.client.pipeline.return_value.rpush().llen().get().get().expire(CODE
CRITICAL⚡t/unit/worker/test_loops.py750 x.obj.event_dispatcher.connection.drain_events.assert_called_once()CODE
CRITICAL⚡t/unit/worker/test_loops.py762 x.obj.event_dispatcher.connection.drain_events.assert_not_called()CODE
CRITICALt/unit/worker/test_loops.py706 x.obj.event_dispatcher.connection.drain_events.assert_called_once_with(timeout=0.1)CODE
CRITICALt/unit/worker/test_strategy.py319 C.consumer.controller.state.revoked.add(task.id)CODE
CRITICAL⚡t/unit/worker/test_worker.py759 self.app.amqp.queues.select_add.assert_called_with(CODE
CRITICALt/integration/test_canvas.py2211 root_id, parent_id, value = res.parent.parent.parent.parent.get(CODE
CRITICALcelery/backends/azureblockblob.py13 from azure.core.exceptions import ResourceExistsError, ResourceNotFoundErrorCODE
Excessive Try-Catch Wrapping188 hits · 203 pts
SeverityFileLineSnippetContext
MEDIUMdocs/changelog_formatter.py22 print(f"Error: {filename} file not found.")CODE
LOWt/smoke/tests/test_tasks.py120 except Exception as err:CODE
LOW…smoke/tests/quorum_queues/test_chord_unlock_routing.py62 except Exception as exc:CODE
LOW⚡t/unit/tasks/test_tasks.py112 except Exception as exc:CODE
LOW⚡t/unit/tasks/test_tasks.py125 except Exception as exc:CODE
LOW⚡t/unit/tasks/test_tasks.py186 except Exception as exc:CODE
LOW⚡t/unit/app/test_schedules.py877 except Exception as exc:CODE
LOWt/unit/app/test_log.py137 except Exception:CODE
LOWt/unit/app/test_trace.py32 except Exception as e:CODE
LOW⚡t/unit/app/test_trace.py92 except Exception:CODE
LOW⚡t/unit/app/test_trace.py109 except Exception:CODE
LOW⚡t/unit/app/test_trace.py132 except Exception as exc:CODE
LOW⚡t/unit/bin/test_control.py153 except Exception as exc:CODE
LOWt/unit/backends/test_database.py394 except Exception as exc:CODE
LOW⚡t/unit/backends/test_elasticsearch.py904 except Exception as exc:CODE
LOWt/unit/backends/test_elasticsearch.py857 except Exception as exc:CODE
LOWt/unit/backends/test_base.py2028 except Exception as exc:CODE
LOWt/unit/backends/test_base.py2091 except Exception as exc:CODE
LOWt/unit/backends/test_base.py2122 except Exception as exc:CODE
MEDIUMt/unit/backends/test_asynchronous.py563def teardown_thread(self, thread):CODE
LOWt/unit/backends/test_asynchronous.py568 except Exception:CODE
LOWt/unit/utils/test_sysinfo.py13except Exception:CODE
MEDIUMt/unit/utils/test_collections.py275def test_exception_info(self):CODE
LOWt/unit/utils/test_collections.py279 except Exception:CODE
MEDIUMt/unit/worker/test_request.py104def test_retry_semipredicate(self):CODE
MEDIUMt/unit/worker/test_request.py416def test_on_failure_WorkerLostError_rejects_with_requeue(self):CODE
MEDIUMt/unit/worker/test_request.py947def get_ei():CODE
LOW⚡t/unit/worker/test_request.py934 except Exception:CODE
LOW⚡t/unit/worker/test_request.py1572 except Exception as exc:CODE
LOWt/unit/worker/test_request.py107 except Exception as exc:CODE
LOWt/unit/worker/test_request.py1595 except Exception as exc:CODE
MEDIUMt/unit/events/test_events.py367def send():CODE
MEDIUMt/unit/events/test_events.py423def publish():CODE
LOWt/unit/events/test_events.py373 except Exception as exc: # pragma: no cover - asserted belowCODE
LOWt/unit/events/test_events.py380 except Exception as exc: # pragma: no cover - asserted belowCODE
LOWt/unit/events/test_events.py426 except Exception as exc: # pragma: no cover - asserted belowCODE
LOWt/integration/conftest.py128 except Exception as e:CODE
MEDIUMt/integration/test_canvas.py300def test_replace_with_chain_that_contains_a_group(self, manager):CODE
LOWt/integration/test_canvas.py3561 except Exception as exc:CODE
LOWt/integration/test_canvas.py4096 except Exception:CODE
LOWt/integration/test_mem_leak_in_exception_handling.py113 except Exception:CODE
LOWt/integration/test_mem_leak_in_exception_handling.py125 except Exception:CODE
LOWt/integration/test_mem_leak_in_exception_handling.py136 except Exception:CODE
LOWt/integration/test_mem_leak_in_exception_handling.py189 except Exception:CODE
LOWt/integration/test_mem_leak_in_exception_handling.py230 except Exception:CODE
LOWt/integration/test_tasks.py518 except Exception as exc:CODE
LOWt/integration/test_tasks.py797 except Exception:CODE
LOWt/integration/test_tasks.py819 except Exception:CODE
LOWt/integration/test_tasks.py844 except Exception:CODE
LOWt/integration/test_redis_backend.py61 except Exception as exc:CODE
LOWt/integration/test_redis_backend.py99 except Exception as exc:CODE
LOWt/integration/test_redis_backend.py185 except Exception as exc:CODE
MEDIUMt/integration/test_redis_backend.py58def collect(res):CODE
MEDIUMt/integration/test_redis_backend.py180def run():CODE
LOWt/integration/test_connection_recovery.py174 except Exception:CODE
LOWcelery/bootsteps.py149 except Exception as exc: # pylint: disable=broad-exceptCODE
LOWcelery/platforms.py554 except Exception: # pylint: disable=broad-exceptCODE
LOWcelery/local.py326 except Exception:CODE
MEDIUMcelery/local.py69def __name__(self):CODE
LOWcelery/beat.py289 except Exception as exc: # pylint: disable=broad-exceptCODE
128 more matches not shown…
Unused Imports174 hits · 174 pts
SeverityFileLineSnippetContext
LOWt/smoke/conftest.py1CODE
LOWt/smoke/conftest.py18CODE
LOWt/smoke/conftest.py19CODE
LOWt/smoke/conftest.py20CODE
LOWt/smoke/conftest.py21CODE
LOWt/smoke/tasks.py3CODE
LOWt/smoke/tasks.py13CODE
LOWt/smoke/tests/test_revoked_sync.py8CODE
LOWt/smoke/tests/test_redis_backend_reentrant.py10CODE
LOWt/smoke/tests/test_gossip.py1CODE
LOWt/smoke/tests/test_beat_remote_control.py1CODE
LOWt/smoke/tests/test_rpc_backend.py11CODE
LOWt/smoke/tests/test_redis_backend_gevent.py9CODE
LOWt/smoke/tests/test_task_queue_max_priority.py1CODE
LOWt/smoke/tests/test_concurrency_auto.py11CODE
LOWt/smoke/tests/test_control.py1CODE
LOWt/smoke/tests/test_memcached_backend.py8CODE
LOWt/smoke/tests/test_chord_headers_exchange.py1CODE
LOWt/smoke/tests/test_task_queue_routing_key.py1CODE
LOWt/smoke/tests/test_tasks.py1CODE
LOWt/smoke/tests/test_worker_shutdown_acks.py12CODE
LOWt/smoke/tests/test_dedup_chain_dispatch.py10CODE
LOWt/smoke/tests/test_worker_heartbeats.py1CODE
LOWt/smoke/tests/test_beat_shutdown.py1CODE
LOWt/smoke/tests/test_thread_safe.py1CODE
LOWt/smoke/tests/test_task_queue_default_exchange.py1CODE
LOWt/smoke/tests/stamping/test_revoke.py1CODE
LOWt/smoke/tests/stamping/conftest.py4CODE
LOWt/smoke/tests/stamping/test_hybrid_cluster.py1CODE
LOWt/smoke/tests/stamping/test_visitor.py1CODE
LOWt/smoke/tests/quorum_queues/test_cycle_detection.py6CODE
LOWt/smoke/tests/quorum_queues/conftest.py1CODE
LOW…smoke/tests/quorum_queues/test_chord_unlock_routing.py8CODE
LOW…/quorum_queues/test_native_delayed_delivery_binding.py8CODE
LOWt/smoke/tests/quorum_queues/test_qos.py8CODE
LOWt/smoke/tests/quorum_queues/test_default_queue_type.py6CODE
LOWt/smoke/tests/failover/test_worker_failover.py1CODE
LOWt/smoke/operations/worker_kill.py1CODE
LOWt/smoke/operations/task_termination.py1CODE
LOWt/smoke/operations/worker_restart.py1CODE
LOWt/smoke/workers/alias.py8CODE
LOWt/smoke/workers/other.py1CODE
LOWt/smoke/workers/alt.py1CODE
LOWt/unit/conftest.py23CODE
LOWt/unit/conftest.py23CODE
LOWt/unit/conftest.py23CODE
LOWt/unit/bin/test_daemonization.py1CODE
LOWt/unit/bin/proj/app2.py1CODE
LOWt/unit/contrib/test_sphinx.py6CODE
LOWt/unit/contrib/test_worker.py7CODE
LOWt/unit/contrib/proj/foo.py1CODE
LOWt/integration/conftest.py9CODE
LOWexamples/celery_http_gateway/urls.py2CODE
LOWexamples/celery_http_gateway/urls.py2CODE
LOWexamples/celery_http_gateway/urls.py2CODE
LOWexamples/stamping/myapp.py34CODE
LOWexamples/django/proj/__init__.py3CODE
LOWexamples/django/proj/urls.py1CODE
LOWexamples/django/proj/urls.py1CODE
LOWexamples/django/proj/urls.py2CODE
114 more matches not shown…
Deep Nesting109 hits · 98 pts
SeverityFileLineSnippetContext
LOWsetup.py64CODE
LOWt/smoke/tests/test_gossip.py20CODE
LOWt/smoke/tests/test_beat_shutdown.py19CODE
LOWt/unit/conftest.py335CODE
LOWt/unit/conftest.py546CODE
LOWt/unit/tasks/test_chord.py160CODE
LOWt/unit/app/test_schedules.py873CODE
LOWt/unit/backends/test_couchdb.py129CODE
LOWt/unit/contrib/test_rdb.py33CODE
LOWt/unit/fixups/test_django.py374CODE
LOWt/unit/worker/test_native_delayed_delivery.py179CODE
LOWt/integration/test_canvas.py84CODE
LOWt/integration/test_tasks.py336CODE
LOWexamples/quorum-queues/myapp.py71CODE
LOWcelery/bootsteps.py137CODE
LOWcelery/platforms.py115CODE
LOWcelery/local.py320CODE
LOWcelery/__init__.py84CODE
LOWcelery/beat.py464CODE
LOWcelery/beat.py616CODE
LOWcelery/beat.py650CODE
LOWcelery/beat.py941CODE
LOWcelery/beat.py1023CODE
LOWcelery/canvas.py115CODE
LOWcelery/canvas.py1015CODE
LOWcelery/canvas.py1178CODE
LOWcelery/canvas.py1820CODE
LOWcelery/canvas.py2324CODE
LOWcelery/schedules.py442CODE
LOWcelery/app/trace.py137CODE
LOWcelery/app/trace.py344CODE
LOWcelery/app/trace.py426CODE
LOWcelery/app/trace.py475CODE
LOWcelery/app/task.py547CODE
LOWcelery/app/control.py512CODE
LOWcelery/app/utils.py338CODE
LOWcelery/app/utils.py426CODE
LOWcelery/app/utils.py477CODE
LOWcelery/app/utils.py428CODE
LOWcelery/app/defaults.py436CODE
LOWcelery/app/base.py945CODE
LOWcelery/bin/control.py26CODE
LOWcelery/bin/shell.py120CODE
LOWcelery/bin/logtool.py78CODE
LOWcelery/backends/gcs.py251CODE
LOWcelery/backends/filesystem.py101CODE
LOWcelery/backends/cache.py40CODE
LOWcelery/backends/cache.py49CODE
LOWcelery/backends/redis.py209CODE
LOWcelery/backends/redis.py236CODE
LOWcelery/backends/redis.py320CODE
LOWcelery/backends/redis.py767CODE
LOWcelery/backends/base.py338CODE
LOWcelery/backends/base.py451CODE
LOWcelery/backends/base.py549CODE
LOWcelery/backends/base.py703CODE
LOWcelery/backends/base.py757CODE
LOWcelery/backends/base.py1349CODE
LOWcelery/backends/database/session.py83CODE
LOWcelery/backends/database/session.py107CODE
49 more matches not shown…
Self-Referential Comments22 hits · 66 pts
SeverityFileLineSnippetContext
MEDIUMt/smoke/tests/test_canvas.py195 # Create the failing group header (same for all tests)COMMENT
MEDIUMt/smoke/tests/test_canvas.py204 # Create the chordCOMMENT
MEDIUMt/unit/tasks/test_canvas.py2834 # Create a chord with header group and body chainCOMMENT
MEDIUMt/unit/tasks/test_canvas.py2855 # Create a chord with header group and body chain (no task_id set)COMMENT
MEDIUMt/unit/tasks/test_tasks.py1837 # Create a mock parent task with no root_idCOMMENT
MEDIUMt/unit/app/test_trace.py21 # Create a nested call stack to have frames to clearCOMMENT
MEDIUMt/unit/bin/proj/pyramid_celery_app.py7# This module defines a mocked Celery application to replicateCOMMENT
MEDIUMt/unit/backends/test_redis.py645 # Create a mock result object with _iter_metaCOMMENT
MEDIUMt/unit/backends/test_redis.py675 # Create a mock result object with _iter_metaCOMMENT
MEDIUMt/unit/backends/test_redis.py705 # Create a mock result object with _iter_metaCOMMENT
MEDIUMt/unit/backends/test_redis.py734 # Create a mock result object with _iter_metaCOMMENT
MEDIUMt/unit/backends/test_redis.py772 # Create a mock result object with _iter_metaCOMMENT
MEDIUMt/unit/backends/test_base.py1076 # Create a mock that properly implements theCOMMENT
MEDIUMt/unit/concurrency/test_prefork.py715 # Create a mock generator (already started, so not gen_not_started)COMMENT
MEDIUMt/unit/worker/test_strategy.py136 # Create a proper mock for task_buckets that supports __getitem__COMMENT
MEDIUMt/unit/worker/test_native_delayed_delivery.py167 # Create a dummy float iteratorCOMMENT
MEDIUMt/unit/worker/test_native_delayed_delivery.py183 # Define a custom errback to check typesCOMMENT
MEDIUMt/unit/worker/test_native_delayed_delivery.py427 # Create a queueCOMMENT
MEDIUMt/unit/worker/test_autoscale.py244 # Create a mock consumer with autoscale and disable_prefetch enabledCOMMENT
MEDIUMt/integration/test_canvas.py3511 # Create the failing group header (same for all tests)COMMENT
MEDIUMcelery/app/trace.py483 # This function is very long because we've unrolled all the callsCOMMENT
MEDIUMcelery/concurrency/asynpool.py571 # This method is called whenever the process sentinel is readable.COMMENT
Cross-Language Confusion14 hits · 65 pts
SeverityFileLineSnippetContext
HIGHt/unit/tasks/test_canvas.py1785 _task_stack.push(self.add)CODE
HIGHt/unit/app/test_log.py413 _task_stack.push(test_task)CODE
HIGHt/unit/app/test_app.py728 _state._task_stack.push(foo)CODE
HIGHt/unit/app/test_app.py1150 _task_stack.push(a3cX1)CODE
HIGHt/unit/backends/test_rpc.py253 _task_stack.push(task)CODE
HIGHt/unit/utils/test_threads.py202 x.push(['foo'])CODE
HIGHt/unit/utils/test_threads.py213 x.push(['foo'])CODE
HIGHt/unit/utils/test_threads.py214 x.push(['bar'])CODE
HIGHt/unit/worker/test_request.py474 req.task.request_stack.push(sentinel)CODE
HIGHcelery/app/task.py507 _task_stack.push(self)CODE
HIGHcelery/app/task.py1248 self.request_stack.push(Context(*args, **{**self.request.__dict__, **kwargs}))CODE
HIGHcelery/utils/threads.py217 >>> ls.push(42)STRING
HIGHcelery/utils/threads.py220 >>> ls.push(23)STRING
HIGHcelery/worker/request.py743 self.task.request_stack.push(self._context)CODE
Decorative Section Separators14 hits · 63 pts
SeverityFileLineSnippetContext
MEDIUM⚡t/unit/tasks/test_context.py88 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/tasks/test_context.py90 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py33# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py35# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py190# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py192# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py344# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/backends/test_asynchronous.py346# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1819 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1821 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1841 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1843 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1909 # ------------------------------------------------------------------COMMENT
MEDIUM⚡t/unit/worker/test_consumer.py1911 # ------------------------------------------------------------------COMMENT
AI Structural Patterns51 hits · 48 pts
SeverityFileLineSnippetContext
LOWt/unit/app/test_control.py73CODE
LOWt/integration/tasks.py355CODE
LOWt/integration/test_canvas.py931CODE
LOWt/integration/test_canvas.py3821CODE
LOWt/integration/test_canvas.py3873CODE
LOWcelery/result.py191CODE
LOWcelery/result.py728CODE
LOWcelery/result.py744CODE
LOWcelery/result.py851CODE
LOWcelery/beat.py123CODE
LOWcelery/canvas.py364CODE
LOWcelery/canvas.py1106CODE
LOWcelery/canvas.py1178CODE
LOWcelery/canvas.py1874CODE
LOWcelery/canvas.py2270CODE
LOWcelery/canvas.py2364CODE
LOWcelery/app/amqp.py62CODE
LOWcelery/app/amqp.py326CODE
LOWcelery/app/amqp.py420CODE
LOWcelery/app/amqp.py508CODE
LOWcelery/app/trace.py344CODE
LOWcelery/app/task.py880CODE
LOWcelery/app/control.py82CODE
LOWcelery/app/control.py755CODE
LOWcelery/app/base.py384CODE
LOWcelery/app/base.py945CODE
LOWcelery/app/base.py1156CODE
LOWcelery/app/base.py1199CODE
LOWcelery/bin/worker.py130CODE
LOWcelery/bin/worker.py340CODE
LOWcelery/security/__init__.py44CODE
LOWcelery/utils/time.py431CODE
LOWcelery/contrib/migrate.py127CODE
LOWcelery/contrib/migrate.py337CODE
LOWcelery/contrib/migrate.py249CODE
LOWcelery/contrib/testing/manager.py48CODE
LOWcelery/contrib/testing/mocks.py11CODE
LOWcelery/concurrency/gevent.py28CODE
LOWcelery/concurrency/asynpool.py112CODE
LOWcelery/concurrency/base.py22CODE
LOWcelery/worker/worker.py432CODE
LOWcelery/worker/control.py53CODE
LOWcelery/worker/request.py96CODE
LOWcelery/worker/consumer/consumer.py192CODE
LOWcelery/events/dispatcher.py58CODE
LOWcelery/events/receiver.py38CODE
LOWcelery/events/state.py161CODE
LOWcelery/events/state.py407CODE
LOWcelery/events/state.py190CODE
LOWcelery/apps/multi.py402CODE
LOWcelery/apps/beat.py46CODE
Over-Commented Block28 hits · 25 pts
SeverityFileLineSnippetContext
LOWexamples/resultgraph/tasks.py1# Example::COMMENT
LOWexamples/django/proj/urls.py1from django.conf.urls import handler404, handler500 # noqaCOMMENT
LOW.github/workflows/codeql-analysis.yml1# For most projects, this workflow file will not need changing; you simply needCOMMENT
LOWcelery/canvas.py621COMMENT
LOWcelery/canvas.py941 # ) | tsum.s() | add.s(1) | group(add.s(1), add.s(1))COMMENT
LOWcelery/canvas.py961 # to begin with.COMMENT
LOWcelery/canvas.py1801 #COMMENT
LOWcelery/app/trace.py841 BaseTask.__call__ = _patched.pop('BaseTask.__call__')COMMENT
LOWcelery/app/task.py241 max_retries = 3COMMENT
LOWcelery/app/task.py261COMMENT
LOWcelery/app/task.py281COMMENT
LOWcelery/app/task.py301COMMENT
LOWcelery/app/task.py321 #: :setting:`task_acks_on_failure_or_timeout` setting.COMMENT
LOWcelery/app/task.py341 #: Configuring this setting only applies to tasks that areCOMMENT
LOWcelery/app/task.py361 #: Tuple of expected exceptions.COMMENT
LOWcelery/backends/cassandra.py241 # differs from other authorization failures, so weCOMMENT
LOWcelery/backends/dynamodb.py361 ))COMMENT
LOWcelery/backends/dynamodb.py381 #COMMENT
LOWcelery/backends/base.py41COMMENT
LOWcelery/backends/base.py181 #: Time to sleep between polling each individual itemCOMMENT
LOWcelery/backends/base.py301 already_failed = (COMMENT
LOWcelery/backends/base.py581 cls = getattr(cls, name)COMMENT
LOWcelery/utils/functional.py361 # In Python 3.14+, inspect.getfullargspec evaluates annotations by defaultCOMMENT
LOWcelery/concurrency/asynpool.py881 total_write_count = [0]COMMENT
LOWcelery/concurrency/asynpool.py1161 # written job._write_to points at the same process, so prefer itCOMMENT
LOWcelery/worker/request.py581 'task-failed',COMMENT
LOWcelery/worker/loops.py101COMMENT
LOWcelery/worker/state.py81#: set of all reserved :class:`~celery.worker.request.Request`'s.COMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHt/smoke/workers/other.py0creates a pytest-celery worker node from the worker container.STRING
HIGHt/smoke/workers/alt.py0creates a pytest-celery worker node from the worker container.STRING
HIGHt/smoke/workers/latest.py0creates a pytest-celery worker node from the worker container.STRING
Fake / Example Data9 hits · 12 pts
SeverityFileLineSnippetContext
LOW⚡t/unit/backends/test_elasticsearch.py729 url = 'elasticsearch+https://fake_user:fake_pass@localhost:9200/index/doc_type'CODE
LOW⚡t/unit/backends/test_elasticsearch.py733 assert x.username == 'fake_user'CODE
LOW⚡t/unit/backends/test_elasticsearch.py740 http_auth=('fake_user', 'fake_pass'),CODE
LOWt/unit/apps/test_multi.py285 self.node = Node('foo@bar.com', options={'-A': 'proj'})CODE
LOWt/unit/apps/test_multi.py292 'foo@bar.com',CODE
LOW⚡t/unit/apps/test_multi.py312 'foo@bar.com',CODE
LOW⚡t/unit/apps/test_multi.py322 'foo@bar.com',CODE
LOWt/unit/apps/test_multi.py426 'foo@bar.com',CODE
LOWt/unit/apps/test_multi.py435 'foo@bar.com',CODE
Modern Structural Boilerplate7 hits · 7 pts
SeverityFileLineSnippetContext
LOWt/integration/conftest.py19logger = logging.getLogger(__name__)CODE
LOWt/integration/test_mem_leak_in_exception_handling.py16logger = logging.getLogger(__name__)CODE
LOWcelery/backends/rpc.py21logger = logging.getLogger(__name__)CODE
LOWcelery/backends/database/__init__.py27logger = logging.getLogger(__name__)CODE
LOWcelery/utils/time.py31logger = logging.getLogger(__name__)CODE
LOWcelery/worker/consumer/delayed_delivery.py112 def _setup_delayed_delivery(self, c: Consumer, broker_url: str) -> None:CODE
LOWcelery/apps/beat.py161 def set_process_title(self) -> None:CODE
Slop Phrases4 hits · 7 pts
SeverityFileLineSnippetContext
LOWexamples/celery_http_gateway/settings.py90 # Don't forget to use absolute paths, not relative paths.COMMENT
MEDIUMcelery/app/amqp.py245 # For example, you can use ``autoexchange = lambda n: None`` to use theCOMMENT
LOWcelery/app/task.py357 #: Warning: Enabling this can cause message loops; make sure you knowCOMMENT
MEDIUMcelery/bin/multi.py71 $ # but you can also modify the options for ranges of, or specific workersSTRING
AI Slop Vocabulary4 hits · 7 pts
SeverityFileLineSnippetContext
LOW⚡t/unit/tasks/test_canvas.py1922 # In the following tests, getting the group ID is a pain so we just useCOMMENT
LOWcelery/app/utils.py271 # no settings, just use new format.COMMENT
LOWcelery/utils/threads.py387 # since each thread has its own greenlet we can just use those asCOMMENT
LOWcelery/worker/consumer/consumer.py642 # Retry disabled, just call connect directly.COMMENT
Overly Generic Function Names4 hits · 6 pts
SeverityFileLineSnippetContext
LOW⚡t/unit/app/test_trace.py87 def test_function():CODE
LOW⚡t/unit/app/test_trace.py104 def test_function():CODE
LOW⚡t/unit/app/test_trace.py127 def test_function():CODE
LOWt/unit/concurrency/test_pool.py10def do_something(i):CODE
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHcelery/worker/consumer/delayed_delivery.py232Validate and split broker URLs. Args: broker_urls: Broker URLs, either as a semicolon-separated strSTRING
Dead Code2 hits · 4 pts
SeverityFileLineSnippetContext
MEDIUMt/unit/utils/test_functional.py210CODE
MEDIUMt/unit/worker/test_loops.py423CODE
Verbosity Indicators2 hits · 3 pts
SeverityFileLineSnippetContext
LOWcelery/bin/worker.py76 # we need to check if the worker pool was configured.COMMENT
LOWcelery/worker/request.py654 # According to the comment below, we need to check if the taskCOMMENT
Redundant / Tautological Comments2 hits · 2 pts
SeverityFileLineSnippetContext
LOWt/integration/test_canvas.py3532 # Check if the message appears in the logs (it shouldn't)COMMENT
LOWexamples/django/demoapp/tasks.py48 retry_jitter=False, # Set False to disable randomization (use exact values: 5s, 10s, 20s)CODE
Structural Annotation Overuse1 hit · 2 pts
SeverityFileLineSnippetContext
LOWcelery/canvas.py984 # WARNING: Be careful not to mutate `options['chain']`.COMMENT