Celery is a distributed task queue. Celery(broker=..., backend=...) configures brokers — findings when broker URL has insecure defaults (redis:// without TLS, amqp:// without TLS). @task decorators accept arbitrary user-controlled args via the queue.
.task().task()Source@celery.task(bind=False, ...) -> Callable
Registers a task. Arguments are user-controlled sources.
return.Celery()Neutralcelery.Celery(main=None, broker=None, backend=None, ...) -> Celery
Celery app. Finding when broker scheme is redis:// or amqp:// without TLS.
| FQN | Field | |
|---|---|---|
| celery | fqns[0] | |
| celery.Celery | fqns[1] |
Wrong FQN → 0 findings. Verify with: change fqns to garbage → must produce 0 results.
from codepathfinder.go_rule import PyCelery