Repository map

A bounded, source-grounded map of the imported repository.

Tests

t/smoke/tests/__init__.py
t/smoke/tests/failover/__init__.py
t/smoke/tests/failover/test_broker_failover.py
t/smoke/tests/failover/test_worker_failover.py
t/smoke/tests/quorum_queues/__init__.py
t/smoke/tests/quorum_queues/conftest.py
t/smoke/tests/quorum_queues/test_chord_unlock_routing.py
t/smoke/tests/quorum_queues/test_cycle_detection.py
t/smoke/tests/quorum_queues/test_default_queue_type.py
t/smoke/tests/quorum_queues/test_native_delayed_delivery.py
t/smoke/tests/quorum_queues/test_native_delayed_delivery_binding.py
t/smoke/tests/quorum_queues/test_qos.py
t/smoke/tests/quorum_queues/test_quorum_queues.py
t/smoke/tests/stamping/__init__.py
t/smoke/tests/stamping/conftest.py
t/smoke/tests/stamping/signals.py
t/smoke/tests/stamping/tasks.py
t/smoke/tests/stamping/test_hybrid_cluster.py
t/smoke/tests/stamping/test_revoke.py
t/smoke/tests/stamping/test_visitor.py
requirements/test.txt
t/smoke/tests/stamping/workers/__init__.py
t/smoke/tests/stamping/workers/legacy.py
t/smoke/tests/test_canvas.py
t/smoke/tests/test_consumer.py
t/smoke/tests/test_control.py
t/smoke/tests/test_dedup_chain_dispatch.py
t/smoke/tests/test_signals.py
t/smoke/tests/test_tasks.py
t/smoke/tests/test_thread_safe.py
t/smoke/tests/test_worker.py

Documentation

docs/AUTHORS.txt
examples/README.rst
.github/ISSUE_TEMPLATE.md
docs/Makefile
examples/app/myapp.py
.github/ISSUE_TEMPLATE/Bug-Report.md
docker/docs/Dockerfile
docs/_ext/celerydocs.py
examples/celery_http_gateway/README.rst
.github/ISSUE_TEMPLATE/Documentation-Bug-Report.md
docs/changelog_formatter.py
examples/celery_http_gateway/__init__.py
.github/ISSUE_TEMPLATE/Enhancement.md
docs/conf.py
examples/celery_http_gateway/manage.py
.github/ISSUE_TEMPLATE/Feature-Request.md
docs/includes/installation.txt
examples/celery_http_gateway/settings.py
.github/ISSUE_TEMPLATE/Major-Version-Release-Checklist.md
SECURITY.md
docs/includes/introduction.txt
examples/celery_http_gateway/tasks.py
.github/ISSUE_TEMPLATE/Minor-Version-Release-Checklist.md
docs/includes/resources.txt
examples/celery_http_gateway/urls.py
.github/ISSUE_TEMPLATE/Patch-Version-Release-Checklist.md
docs/sec/CELERYSA-0001.txt
examples/django/README.rst
docs/sec/CELERYSA-0002.txt
examples/django/demoapp/__init__.py
.github/PULL_REQUEST_TEMPLATE.md
docs/sec/CELERYSA-0003.txt
examples/django/demoapp/migrations/0001_initial.py
.github/copilot-instructions.md
docs/spelling_wordlist.txt
examples/django/demoapp/migrations/__init__.py
docs/templates/readme.txt
examples/django/demoapp/models.py
examples/django/demoapp/tasks.py
examples/django/demoapp/views.py
examples/django/manage.py
examples/django/proj/__init__.py
examples/django/proj/celery.py
examples/django/proj/settings.py
examples/django/proj/urls.py
examples/django/proj/wsgi.py
examples/django/requirements.txt
examples/eventlet/README.rst
examples/eventlet/bulk_task_producer.py
examples/eventlet/celeryconfig.py
examples/eventlet/tasks.py
examples/eventlet/webcrawler.py
examples/gevent/README.rst
examples/gevent/celeryconfig.py
examples/gevent/tasks.py
examples/next-steps/proj/__init__.py
examples/next-steps/proj/celery.py
examples/next-steps/proj/tasks.py
examples/next-steps/setup.py
examples/periodic-tasks/myapp.py
examples/pydantic/__init__.py
examples/pydantic/tasks.py
examples/quorum-queues/declare_queue.py
examples/quorum-queues/myapp.py
examples/quorum-queues/setup_cluster.sh
examples/quorum-queues/test_cluster.sh
examples/resultgraph/tasks.py
examples/security/mysecureapp.py
examples/stamping/config.py
examples/stamping/examples.py
examples/stamping/myapp.py
examples/stamping/revoke_example.py
examples/stamping/tasks.py
examples/stamping/visitors.py
examples/tutorial/tasks.py

Source

celery/app/__init__.py
celery/app/amqp.py
celery/app/annotations.py
celery/app/autoretry.py
celery/app/backends.py
celery/app/base.py
celery/app/builtins.py
celery/app/control.py
celery/app/defaults.py
celery/app/events.py
celery/app/log.py
celery/app/registry.py
celery/app/routes.py
celery/app/task.py
celery/app/trace.py
celery/app/utils.py
t/unit/app/__init__.py
t/unit/app/test_amqp.py
t/unit/app/test_annotations.py
t/unit/app/test_app.py
t/unit/app/test_backends.py
t/unit/app/test_beat.py
t/unit/app/test_builtins.py
t/unit/app/test_celery.py
t/unit/app/test_control.py
t/unit/app/test_defaults.py
t/unit/app/test_exceptions.py
t/unit/app/test_loaders.py
t/unit/app/test_log.py
t/unit/app/test_preload_cli.py
t/unit/app/test_registry.py
t/unit/app/test_routes.py
t/unit/app/test_schedules.py
t/unit/app/test_trace.py
t/unit/app/test_utils.py

Configuration

.github/FUNDING.yml
docker/Dockerfile
pyproject.toml
.github/ISSUE_TEMPLATE/config.yml
.github/dependabot.yml
.github/opencollective.yml
.github/workflows/codeql-analysis.yml
.github/workflows/docker.yml
.github/workflows/integration-tests.yml
.github/workflows/linter.yml
.github/workflows/python-package.yml
.github/workflows/semgrep.yml
.github/workflows/smoke-tests.yml

Other files

.pre-commit-config.yaml
celery/__init__.py
extra/release/attribution.py
helm-chart/Chart.yaml
requirements/README.rst
t/__init__.py
.readthedocs.yaml
celery/__main__.py
docker/docker-compose.yml
extra/release/gen-cert.sh
helm-chart/README.rst
requirements/constraints.txt
t/benchmarks/bench_worker.py
CONTRIBUTORS.txt
celery/_state.py
extra/release/sphinx2rst_config.py
helm-chart/templates/configmap.yaml
requirements/default.txt
t/integration/__init__.py
LICENSE
docker/scripts/create-linux-user.sh
extra/supervisord/celery.sh
helm-chart/templates/deployment.yaml
requirements/deps/mock.txt
t/integration/conftest.py
Makefile
docker/scripts/install-couchbase.sh
extra/supervisord/celerybeat.conf
helm-chart/templates/secret.yaml
requirements/dev.txt
t/integration/django_settings.py
README.rst
docker/scripts/install-pyenv.sh
extra/supervisord/celeryd.conf
helm-chart/templates/serviceaccount.yaml
requirements/docs.txt
t/integration/serialization_config.py
extra/supervisord/supervisord.conf
helm-chart/values.yaml
requirements/extras/arangodb.txt
t/integration/tasks.py
bandit.json
extra/systemd/celery.conf
requirements/extras/auth.txt
t/integration/test_backend.py
requirements/extras/azureblockblob.txt
t/integration/test_canvas.py
setup.py
requirements/extras/brotli.txt
t/integration/test_connection_recovery.py
tox.ini
requirements/extras/cassandra.txt
t/integration/test_database_backend.py
requirements/extras/consul.txt
t/integration/test_inspect.py
requirements/extras/cosmosdbsql.txt
t/integration/test_loader.py
requirements/extras/couchbase.txt
t/integration/test_mem_leak_in_exception_handling.py
requirements/extras/couchdb.txt
t/integration/test_security.py
requirements/extras/django.txt
t/integration/test_serialization.py
requirements/extras/dynamodb.txt
t/integration/test_tasks.py
requirements/extras/elasticsearch.txt
t/integration/test_worker.py
requirements/extras/eventlet.txt
t/integration/worker_config.py
celery/apps/__init__.py
requirements/extras/gcpubsub.txt
t/skip.py
celery/apps/beat.py
requirements/extras/gcs.txt
t/smoke/__init__.py
celery/apps/multi.py
requirements/extras/gevent.txt
t/smoke/conftest.py
celery/apps/worker.py
requirements/extras/librabbitmq.txt
t/smoke/operations/__init__.py
celery/backends/__init__.py
requirements/extras/memcache.txt
t/smoke/operations/task_termination.py
celery/backends/arangodb.py
requirements/extras/mongodb.txt
t/smoke/operations/worker_kill.py
celery/backends/asynchronous.py
requirements/extras/msgpack.txt
t/smoke/operations/worker_restart.py
celery/backends/azureblockblob.py
requirements/extras/pydantic.txt
t/smoke/redis.conf
celery/backends/base.py
requirements/extras/pymemcache.txt
t/smoke/signals.py
celery/backends/cache.py
requirements/extras/pyro.txt
t/smoke/tasks.py
celery/backends/cassandra.py