celery/celery

Pattern Findings

2271 matches across 18 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers1756 hits · 1555 pts

Severity	File	Line	Snippet
LOW	docs/conf.py	90	def configcheck_project_settings():
LOW	docs/conf.py	103	def configcheck_should_ignore(setting):
LOW	docs/_ext/celerydocs.py	127	def maybe_resolve_abbreviations(app, env, node, contnode):
LOW	t/smoke/signals.py	12	def worker_process_init_handler(sender, **kwargs):
LOW	t/smoke/signals.py	17	def worker_process_shutdown_handler(sender, pid, exitcode, **kwargs):
LOW	t/smoke/tasks.py	42	def soft_time_limit_lower_than_time_limit():
LOW	t/smoke/tasks.py	47	def soft_time_limit_must_exceed_time_limit():
LOW	t/smoke/tasks.py	65	def self_termination_system_exit():
LOW	t/smoke/tasks.py	71	def countdown_task_with_retry(self):
LOW	t/smoke/tasks.py	79	def non_eta_task_with_retries(self):
LOW	t/smoke/tasks.py	93	def self_termination_delay_timeout():
LOW	t/smoke/tasks.py	99	def self_termination_exhaust_memory():
LOW	t/smoke/tests/test_signals.py	42	def before_task_publish_handler(args, *kwargs):
LOW	t/smoke/tests/test_signals.py	54	def after_task_publish_handler(args, *kwargs):
LOW	t/smoke/tests/test_control.py	14	def test_shutdown_exit_with_zero(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_canvas.py	38	def test_chain_gets_last_task_id_with_failing_tasks_in_chain(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_canvas.py	56	def test_upgrade_to_chord_inside_chains(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_canvas.py	144	def test_chord_error_propagation_with_different_body_types(
LOW	t/smoke/tests/test_canvas.py	185	def test_pending_tasks_released_on_forget(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	37	def test_restart_during_task_execution(
LOW	t/smoke/tests/test_worker.py	48	def test_restart_between_task_execution(
LOW	t/smoke/tests/test_worker.py	86	def test_multiple_warm_shutdown_does_nothing(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	115	def test_hard_shutdown_from_warm(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	131	def test_hard_shutdown_from_cold(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	162	def test_shutdown_with_long_running_tasks(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	199	def test_hard_shutdown_from_cold(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	238	def test_hard_shutdown_from_soft(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	253	def test_task_completes_during_soft_shutdown(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	282	def test_task_completes_during_soft_shutdown_with_time_limit(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	338	def test_hard_shutdown_from_soft(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	370	def test_soft_shutdown_reset_visibility_timeout(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	391	def test_soft_shutdown_reset_visibility_timeout_group_one_finish(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	416	def test_soft_shutdown_reset_visibility_timeout_group_none_finish(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	450	def test_soft_shutdown_reset_visibility_timeout(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_worker.py	471	def test_soft_shutdown_reset_visibility_timeout_group_one_finish(
LOW	t/smoke/tests/test_tasks.py	33	def test_child_process_respawn(
LOW	t/smoke/tests/test_tasks.py	53	def wait_for_two_celery_processes():
LOW	t/smoke/tests/test_tasks.py	98	def test_terminated_task_logs_correct_error(
LOW	t/smoke/tests/test_tasks.py	137	def test_soft_time_limit_lower_than_time_limit(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_tasks.py	143	def test_soft_time_limit_must_exceed_time_limit(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_consumer.py	40	def test_reducing_prefetch_count(self, celery_setup: CeleryTestSetup, expected_running_tasks_count: int):
LOW	t/smoke/tests/test_consumer.py	63	def test_prefetch_count_restored(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_consumer.py	86	def test_max_prefetch_passed_on_broker_restart(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_consumer.py	107	def test_max_prefetch_not_passed_on_broker_restart(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_consumer.py	121	def test_worker_consume_tasks_after_redis_broker_restart(
LOW	t/smoke/tests/test_consumer.py	149	def test_worker_does_not_hang_on_broker_connection_loss(
LOW	t/smoke/tests/test_dedup_chain_dispatch.py	33	def test_reject_requeue_completes_chain(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_dedup_chain_dispatch.py	42	def test_dedup_dispatches_chain_on_redelivery(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_dedup_chain_dispatch.py	51	def test_dedup_dispatches_callback_on_redelivery(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/test_thread_safe.py	50	def test_multithread_task_publish(
LOW	t/smoke/tests/test_thread_safe.py	58	def after_task_publish_handler(args, *kwargs):
LOW	t/smoke/tests/stamping/test_revoke.py	47	def test_revoke_by_stamped_headers_after_publish(
LOW	t/smoke/tests/stamping/test_revoke.py	63	def test_revoke_by_stamped_headers_before_publish(
LOW	t/smoke/tests/stamping/conftest.py	10	def default_rabbitmq_broker_image() -> str:
LOW	t/smoke/tests/stamping/test_hybrid_cluster.py	12	def get_hybrid_clusters_matrix() -> list[list[str]]:
LOW	t/smoke/tests/stamping/test_hybrid_cluster.py	83	def test_multiple_stamps_multiple_workers(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/stamping/test_hybrid_cluster.py	109	def test_stamping_on_replace_with_legacy_worker_in_cluster(
LOW	t/smoke/tests/quorum_queues/test_cycle_detection.py	16	def test_countdown_task_with_retry(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/quorum_queues/test_cycle_detection.py	22	def test_non_eta_task_with_multiple_retries(self, celery_setup: CeleryTestSetup):
LOW	t/smoke/tests/quorum_queues/conftest.py	34	def default_rabbitmq_broker_image() -> str:
1696 more matches not shown…

Hallucination Indicators16 hits · 210 pts

Severity	File	Line	Snippet
CRITICAL	t/unit/tasks/test_canvas.py	269	x.type.app.control.election.assert_called()
CRITICAL	t/unit/app/test_app.py	1655	self.app.amqp.queues.select.assert_called_with({'foo', 'bar'})
CRITICAL	t/unit/backends/test_redis.py	217	consumer.backend.client.connection_pool.reset.assert_called_once()
CRITICAL	t/unit/backends/test_redis.py	223	consumer.backend.client.connection_pool.reset.reset_mock()
CRITICAL	t/unit/backends/test_redis.py	226	consumer.backend.client.connection_pool.reset.assert_called_once()
CRITICAL	t/unit/backends/test_redis.py	232	consumer.backend.client.connection_pool.reset.reset_mock()
CRITICAL	t/unit/backends/test_redis.py	1394	self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(
CRITICAL	t/unit/backends/test_redis.py	1406	self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(
CRITICAL	t/unit/backends/test_redis.py	1422	self.b.client.pipeline.return_value.rpush().llen().get().get().expire(
CRITICAL	t/unit/backends/test_redis.py	1438	self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(
CRITICAL	t/unit/backends/test_redis.py	1362	self.b.client.pipeline.return_value.zadd().zcount().get().get().expire(
CRITICAL	t/unit/backends/test_redis.py	1378	self.b.client.pipeline.return_value.rpush().llen().get().get().expire(
CRITICAL	t/unit/worker/test_strategy.py	283	C.consumer.controller.state.revoked.add(task.id)
CRITICAL	t/unit/worker/test_worker.py	733	self.app.amqp.queues.select_add.assert_called_with(
CRITICAL	t/integration/test_canvas.py	1945	root_id, parent_id, value = res.parent.parent.parent.parent.get(
CRITICAL	celery/backends/azureblockblob.py	13	from azure.core.exceptions import ResourceExistsError, ResourceNotFoundError

Excessive Try-Catch Wrapping152 hits · 168 pts

Severity	File	Line	Snippet
MEDIUM	docs/changelog_formatter.py	22	print(f"Error: {filename} file not found.")
LOW	t/smoke/tests/test_tasks.py	107	except Exception as err:
LOW	…smoke/tests/quorum_queues/test_chord_unlock_routing.py	62	except Exception as exc:
LOW	t/unit/tasks/test_tasks.py	112	except Exception as exc:
LOW	t/unit/tasks/test_tasks.py	125	except Exception as exc:
LOW	t/unit/tasks/test_tasks.py	186	except Exception as exc:
LOW	t/unit/app/test_schedules.py	672	except Exception as exc:
LOW	t/unit/app/test_log.py	102	except Exception:
LOW	t/unit/app/test_trace.py	32	except Exception as e:
LOW	t/unit/app/test_trace.py	92	except Exception:
LOW	t/unit/app/test_trace.py	109	except Exception:
LOW	t/unit/app/test_trace.py	132	except Exception as exc:
LOW	t/unit/bin/test_control.py	153	except Exception as exc:
LOW	t/unit/backends/test_database.py	317	except Exception as exc:
LOW	t/unit/backends/test_elasticsearch.py	904	except Exception as exc:
LOW	t/unit/backends/test_elasticsearch.py	857	except Exception as exc:
LOW	t/unit/backends/test_base.py	1558	except Exception as exc:
LOW	t/unit/backends/test_base.py	1621	except Exception as exc:
LOW	t/unit/backends/test_base.py	1652	except Exception as exc:
MEDIUM	t/unit/backends/test_asynchronous.py	577	def teardown_thread(self, thread):
LOW	t/unit/backends/test_asynchronous.py	582	except Exception:
LOW	t/unit/utils/test_sysinfo.py	10	except Exception:
LOW	t/unit/utils/test_collections.py	142	except Exception:
MEDIUM	t/unit/utils/test_collections.py	138	def test_exception_info(self):
MEDIUM	t/unit/worker/test_request.py	104	def test_retry_semipredicate(self):
MEDIUM	t/unit/worker/test_request.py	338	def test_on_failure_WorkerLostError_rejects_with_requeue(self):
MEDIUM	t/unit/worker/test_request.py	847	def get_ei():
LOW	t/unit/worker/test_request.py	834	except Exception:
LOW	t/unit/worker/test_request.py	1404	except Exception as exc:
LOW	t/unit/worker/test_request.py	107	except Exception as exc:
LOW	t/unit/worker/test_request.py	1427	except Exception as exc:
LOW	t/integration/conftest.py	110	except Exception as e:
MEDIUM	t/integration/test_canvas.py	348	def test_chain_error_handler_with_eta(self, manager):
LOW	t/integration/test_canvas.py	3297	except Exception as exc:
LOW	t/integration/test_canvas.py	3779	except Exception:
LOW	t/integration/test_mem_leak_in_exception_handling.py	113	except Exception:
LOW	t/integration/test_mem_leak_in_exception_handling.py	125	except Exception:
LOW	t/integration/test_mem_leak_in_exception_handling.py	136	except Exception:
LOW	t/integration/test_mem_leak_in_exception_handling.py	189	except Exception:
LOW	t/integration/test_mem_leak_in_exception_handling.py	230	except Exception:
LOW	t/integration/test_tasks.py	471	except Exception as exc:
LOW	t/integration/test_tasks.py	750	except Exception:
LOW	t/integration/test_tasks.py	772	except Exception:
LOW	t/integration/test_tasks.py	797	except Exception:
LOW	celery/bootsteps.py	149	except Exception as exc: # pylint: disable=broad-except
LOW	celery/platforms.py	490	except Exception: # pylint: disable=broad-except
LOW	celery/local.py	326	except Exception:
MEDIUM	celery/local.py	69	def __name__(self):
LOW	celery/beat.py	283	except Exception as exc: # pylint: disable=broad-except
LOW	celery/beat.py	411	except Exception as exc: # pylint: disable=broad-except
LOW	celery/beat.py	540	except Exception as exc: # pylint: disable=broad-except
MEDIUM	celery/beat.py	427	def _do_sync(self):
LOW	celery/app/trace.py	549	except Exception as exc:
LOW	celery/app/trace.py	604	except Exception as exc:
LOW	celery/app/trace.py	670	except Exception as exc:
LOW	celery/app/trace.py	677	except Exception as exc:
LOW	celery/app/trace.py	698	except Exception as exc:
LOW	celery/app/task.py	863	except Exception as exc:
LOW	celery/app/builtins.py	67	except Exception as exc:
LOW	celery/app/builtins.py	82	except Exception as exc: # pylint: disable=broad-except
92 more matches not shown…

Unused Imports157 hits · 157 pts

Severity	File	Line
LOW	t/smoke/conftest.py	1
LOW	t/smoke/conftest.py	14
LOW	t/smoke/conftest.py	15
LOW	t/smoke/conftest.py	16
LOW	t/smoke/conftest.py	17
LOW	t/smoke/tasks.py	3
LOW	t/smoke/tasks.py	13
LOW	t/smoke/tests/test_tasks.py	1
LOW	t/smoke/tests/test_dedup_chain_dispatch.py	10
LOW	t/smoke/tests/test_thread_safe.py	1
LOW	t/smoke/tests/stamping/test_revoke.py	1
LOW	t/smoke/tests/stamping/conftest.py	4
LOW	t/smoke/tests/stamping/test_hybrid_cluster.py	1
LOW	t/smoke/tests/stamping/test_visitor.py	1
LOW	t/smoke/tests/quorum_queues/test_cycle_detection.py	6
LOW	t/smoke/tests/quorum_queues/conftest.py	1
LOW	…smoke/tests/quorum_queues/test_chord_unlock_routing.py	8
LOW	…/quorum_queues/test_native_delayed_delivery_binding.py	8
LOW	t/smoke/tests/quorum_queues/test_qos.py	8
LOW	t/smoke/tests/quorum_queues/test_default_queue_type.py	6
LOW	t/smoke/tests/failover/test_worker_failover.py	1
LOW	t/smoke/operations/worker_kill.py	1
LOW	t/smoke/operations/task_termination.py	1
LOW	t/smoke/operations/worker_restart.py	1
LOW	t/smoke/workers/other.py	1
LOW	t/smoke/workers/alt.py	1
LOW	t/unit/conftest.py	23
LOW	t/unit/conftest.py	23
LOW	t/unit/conftest.py	23
LOW	t/unit/bin/test_daemonization.py	1
LOW	t/unit/bin/proj/app2.py	1
LOW	t/unit/contrib/test_sphinx.py	6
LOW	t/unit/contrib/test_worker.py	7
LOW	t/unit/contrib/proj/foo.py	1
LOW	t/integration/conftest.py	9
LOW	examples/celery_http_gateway/urls.py	2
LOW	examples/celery_http_gateway/urls.py	2
LOW	examples/celery_http_gateway/urls.py	2
LOW	examples/stamping/myapp.py	34
LOW	examples/django/proj/__init__.py	3
LOW	examples/django/proj/urls.py	1
LOW	examples/django/proj/urls.py	1
LOW	examples/django/proj/urls.py	2
LOW	examples/django/proj/urls.py	2
LOW	celery/__init__.py	75
LOW	celery/__init__.py	75
LOW	celery/__init__.py	76
LOW	celery/__init__.py	77
LOW	celery/__init__.py	78
LOW	celery/__init__.py	79
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	80
LOW	celery/__init__.py	82
97 more matches not shown…

Deep Nesting92 hits · 88 pts

Severity	File	Line
LOW	setup.py	64
LOW	t/unit/conftest.py	314
LOW	t/unit/conftest.py	525
LOW	t/unit/tasks/test_chord.py	134
LOW	t/unit/app/test_schedules.py	668
LOW	t/unit/backends/test_couchdb.py	129
LOW	t/unit/contrib/test_rdb.py	33
LOW	t/unit/fixups/test_django.py	198
LOW	t/unit/worker/test_native_delayed_delivery.py	179
LOW	t/unit/worker/test_consumer.py	624
LOW	t/integration/test_canvas.py	83
LOW	t/integration/test_tasks.py	289
LOW	examples/quorum-queues/myapp.py	71
LOW	celery/bootsteps.py	137
LOW	celery/platforms.py	106
LOW	celery/local.py	320
LOW	celery/__init__.py	88
LOW	celery/beat.py	569
LOW	celery/beat.py	633
LOW	celery/canvas.py	74
LOW	celery/canvas.py	960
LOW	celery/canvas.py	1120
LOW	celery/canvas.py	2191
LOW	celery/schedules.py	434
LOW	celery/app/trace.py	137
LOW	celery/app/trace.py	344
LOW	celery/app/trace.py	426
LOW	celery/app/trace.py	475
LOW	celery/app/task.py	536
LOW	celery/app/control.py	512
LOW	celery/app/utils.py	327
LOW	celery/app/utils.py	378
LOW	celery/app/utils.py	329
LOW	celery/app/defaults.py	428
LOW	celery/app/base.py	846
LOW	celery/bin/control.py	26
LOW	celery/bin/shell.py	120
LOW	celery/bin/logtool.py	78
LOW	celery/backends/gcs.py	247
LOW	celery/backends/filesystem.py	98
LOW	celery/backends/redis.py	575
LOW	celery/backends/base.py	344
LOW	celery/backends/base.py	441
LOW	celery/backends/base.py	565
LOW	celery/backends/base.py	619
LOW	celery/backends/base.py	1172
LOW	celery/backends/database/session.py	80
LOW	celery/utils/log.py	45
LOW	celery/utils/log.py	145
LOW	celery/utils/saferepr.py	158
LOW	celery/utils/saferepr.py	197
LOW	celery/utils/imports.py	48
LOW	celery/utils/imports.py	69
LOW	celery/utils/timer2.py	79
LOW	celery/utils/threads.py	62
LOW	celery/utils/functional.py	215
LOW	celery/utils/functional.py	318
LOW	celery/utils/collections.py	544
LOW	celery/utils/objects.py	15
LOW	celery/utils/serialization.py	233
32 more matches not shown…

Decorative Section Separators14 hits · 63 pts

Severity	File	Line	Snippet
MEDIUM	t/unit/tasks/test_context.py	88	# ------------------------------------------------------------------
MEDIUM	t/unit/tasks/test_context.py	90	# ------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	31	# ---------------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	33	# ---------------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	170	# ---------------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	172	# ---------------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	324	# ---------------------------------------------------------------------------
MEDIUM	t/unit/backends/test_asynchronous.py	326	# ---------------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1291	# ------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1293	# ------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1313	# ------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1315	# ------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1348	# ------------------------------------------------------------------
MEDIUM	t/unit/worker/test_consumer.py	1350	# ------------------------------------------------------------------

Cross-File Repetition12 hits · 60 pts

Severity	File	Snippet
HIGH	t/smoke/workers/other.py	creates a pytest-celery worker node from the worker container.
HIGH	t/smoke/workers/alt.py	creates a pytest-celery worker node from the worker container.
HIGH	t/smoke/workers/latest.py	creates a pytest-celery worker node from the worker container.
HIGH	t/unit/app/test_app.py	test pydantic task receiving and returning an optional argument.
HIGH	t/unit/app/test_app.py	test pydantic task receiving and returning an optional argument.
HIGH	t/unit/app/test_app.py	test pydantic task receiving and returning an optional argument.
HIGH	t/integration/test_canvas.py	this test is built to reproduce the github issue https://github.com/celery/celery/issues/5958 the issue describes a canv
HIGH	t/integration/test_canvas.py	this test is built to reproduce the github issue https://github.com/celery/celery/issues/5958 the issue describes a canv
HIGH	t/integration/test_canvas.py	this test is built to reproduce the github issue https://github.com/celery/celery/issues/5958 the issue describes a canv
HIGH	celery/app/builtins.py	no longer used, but here for backwards compatibility.
HIGH	celery/app/builtins.py	no longer used, but here for backwards compatibility.
HIGH	celery/app/builtins.py	no longer used, but here for backwards compatibility.

Cross-Language Confusion12 hits · 55 pts

Severity	File	Line	Snippet
HIGH	t/unit/tasks/test_canvas.py	1108	_task_stack.push(self.add)
HIGH	t/unit/app/test_log.py	327	_task_stack.push(test_task)
HIGH	t/unit/app/test_app.py	476	_state._task_stack.push(foo)
HIGH	t/unit/app/test_app.py	898	_task_stack.push(a3cX1)
HIGH	t/unit/backends/test_rpc.py	252	_task_stack.push(task)
HIGH	t/unit/utils/test_threads.py	60	x.push(['foo'])
HIGH	t/unit/utils/test_threads.py	71	x.push(['foo'])
HIGH	t/unit/utils/test_threads.py	72	x.push(['bar'])
HIGH	celery/app/task.py	496	_task_stack.push(self)
HIGH	celery/app/task.py	1235	self.request_stack.push(Context(args, {self.request.__dict__, *kwargs}))
HIGH	celery/utils/threads.py	163	>>> ls.push(42)
HIGH	celery/utils/threads.py	166	>>> ls.push(23)

Self-Referential Comments17 hits · 51 pts

Severity	File	Line	Snippet
MEDIUM	t/smoke/tests/test_canvas.py	160	# Create the failing group header (same for all tests)
MEDIUM	t/smoke/tests/test_canvas.py	169	# Create the chord
MEDIUM	t/unit/tasks/test_canvas.py	1995	# Create a chord with header group and body chain
MEDIUM	t/unit/tasks/test_canvas.py	2016	# Create a chord with header group and body chain (no task_id set)
MEDIUM	t/unit/tasks/test_tasks.py	1712	# Create a mock parent task with no root_id
MEDIUM	t/unit/app/test_trace.py	21	# Create a nested call stack to have frames to clear
MEDIUM	t/unit/bin/proj/pyramid_celery_app.py	7	# This module defines a mocked Celery application to replicate
MEDIUM	t/unit/backends/test_base.py	823	# Create a mock that properly implements the
MEDIUM	t/unit/concurrency/test_prefork.py	580	# Create a mock generator (already started, so not gen_not_started)
MEDIUM	t/unit/worker/test_strategy.py	130	# Create a proper mock for task_buckets that supports __getitem__
MEDIUM	t/unit/worker/test_native_delayed_delivery.py	167	# Create a dummy float iterator
MEDIUM	t/unit/worker/test_native_delayed_delivery.py	183	# Define a custom errback to check types
MEDIUM	t/unit/worker/test_native_delayed_delivery.py	427	# Create a queue
MEDIUM	t/unit/worker/test_autoscale.py	244	# Create a mock consumer with autoscale and disable_prefetch enabled
MEDIUM	t/integration/test_canvas.py	3247	# Create the failing group header (same for all tests)
MEDIUM	celery/app/trace.py	483	# This function is very long because we've unrolled all the calls
MEDIUM	celery/concurrency/asynpool.py	496	# This method is called whenever the process sentinel is readable.

Over-Commented Block19 hits · 19 pts

Severity	File	Line	Snippet
LOW	examples/resultgraph/tasks.py	1	# Example::
LOW	examples/django/proj/urls.py	1	from django.conf.urls import handler404, handler500 # noqa
LOW	.github/workflows/codeql-analysis.yml	1	# For most projects, this workflow file will not need changing; you simply need
LOW	celery/__init__.py	1	"""Distributed Task Queue."""
LOW	celery/canvas.py	881	# Issue #5354 reported that the following type of canvases
LOW	celery/canvas.py	901	# variable above.
LOW	celery/canvas.py	1801	# end up messing up chord counts and there are all sorts of
LOW	celery/app/task.py	241	max_retries = 3
LOW	celery/app/task.py	261
LOW	celery/app/task.py	281
LOW	celery/app/task.py	301
LOW	celery/app/task.py	321	#: :setting:`task_acks_on_failure_or_timeout` setting.
LOW	celery/app/task.py	341	#: Configuring this setting only applies to tasks that are
LOW	celery/app/task.py	361	#: Tuple of expected exceptions.
LOW	celery/backends/dynamodb.py	361	#
LOW	celery/backends/base.py	201	# this is most likely to be exclusive with being a direct part of a
LOW	celery/backends/base.py	481	# could exploit a stored command vulnerability to execute arbitrary
LOW	celery/concurrency/asynpool.py	801	self.on_inqueue_close = on_inqueue_close
LOW	celery/worker/loops.py	101	# Reset the hub on error (e.g. connection loss) to clean up

Slop Phrases4 hits · 7 pts

Severity	File	Line	Snippet
LOW	examples/celery_http_gateway/settings.py	90	# Don't forget to use absolute paths, not relative paths.
MEDIUM	celery/app/amqp.py	239	# For example, you can use ``autoexchange = lambda n: None`` to use the
LOW	celery/app/task.py	357	#: Warning: Enabling this can cause message loops; make sure you know
MEDIUM	celery/bin/multi.py	71	$ # but you can also modify the options for ranges of, or specific workers

AI Slop Vocabulary4 hits · 7 pts

Severity	File	Line	Snippet
LOW	t/unit/tasks/test_canvas.py	1245	# In the following tests, getting the group ID is a pain so we just use
LOW	celery/app/utils.py	261	# no settings, just use new format.
LOW	celery/utils/threads.py	333	# since each thread has its own greenlet we can just use those as
LOW	celery/worker/consumer/consumer.py	607	# Retry disabled, just call connect directly.

Overly Generic Function Names4 hits · 6 pts

Severity	File	Line	Snippet
LOW	t/unit/app/test_trace.py	87	def test_function():
LOW	t/unit/app/test_trace.py	104	def test_function():
LOW	t/unit/app/test_trace.py	127	def test_function():
LOW	t/unit/concurrency/test_pool.py	10	def do_something(i):

Docstring Block Structure1 hit · 5 pts

Severity	File	Line	Snippet
HIGH	celery/worker/consumer/delayed_delivery.py	232	Validate and split broker URLs. Args: broker_urls: Broker URLs, either as a semicolon-separated str

Dead Code2 hits · 4 pts

Severity	File	Line	Snippet
MEDIUM	t/unit/utils/test_functional.py	166
MEDIUM	t/unit/worker/test_loops.py	401

Fake / Example Data4 hits · 4 pts

Severity	File	Line	Snippet
LOW	t/unit/apps/test_multi.py	183	self.node = Node('foo@bar.com', options={'-A': 'proj'})
LOW	t/unit/apps/test_multi.py	190	'foo@bar.com',
LOW	t/unit/apps/test_multi.py	284	'foo@bar.com',
LOW	t/unit/apps/test_multi.py	293	'foo@bar.com',

Redundant / Tautological Comments3 hits · 4 pts

Severity	File	Line	Snippet
LOW	t/integration/test_canvas.py	3268	# Check if the message appears in the logs (it shouldn't)
LOW	examples/django/demoapp/tasks.py	48	retry_jitter=False, # Set False to disable randomization (use exact values: 5s, 10s, 20s)
LOW	celery/schedules.py	677	# Check if the last feasible date is within the deadline

Verbosity Indicators2 hits · 3 pts

Severity	File	Line	Snippet
LOW	celery/bin/worker.py	54	# we need to check if the worker pool was configured.
LOW	celery/worker/request.py	638	# According to the comment below, we need to check if the task

Score History

Severity Breakdown

Pattern Findings