Repository map
A bounded, source-grounded map of the imported repository.
Tests
t/smoke/tests/__init__.pyt/smoke/tests/failover/__init__.pyt/smoke/tests/failover/test_broker_failover.pyt/smoke/tests/failover/test_worker_failover.pyt/smoke/tests/quorum_queues/__init__.pyt/smoke/tests/quorum_queues/conftest.pyt/smoke/tests/quorum_queues/test_chord_unlock_routing.pyt/smoke/tests/quorum_queues/test_cycle_detection.pyt/smoke/tests/quorum_queues/test_default_queue_type.pyt/smoke/tests/quorum_queues/test_native_delayed_delivery.pyt/smoke/tests/quorum_queues/test_native_delayed_delivery_binding.pyt/smoke/tests/quorum_queues/test_qos.pyt/smoke/tests/quorum_queues/test_quorum_queues.pyt/smoke/tests/stamping/__init__.pyt/smoke/tests/stamping/conftest.pyt/smoke/tests/stamping/signals.pyt/smoke/tests/stamping/tasks.pyt/smoke/tests/stamping/test_hybrid_cluster.pyt/smoke/tests/stamping/test_revoke.pyt/smoke/tests/stamping/test_visitor.pyrequirements/test.txtt/smoke/tests/stamping/workers/__init__.pyt/smoke/tests/stamping/workers/legacy.pyt/smoke/tests/test_canvas.pyt/smoke/tests/test_consumer.pyt/smoke/tests/test_control.pyt/smoke/tests/test_dedup_chain_dispatch.pyt/smoke/tests/test_signals.pyt/smoke/tests/test_tasks.pyt/smoke/tests/test_thread_safe.pyt/smoke/tests/test_worker.py
Documentation
docs/AUTHORS.txtexamples/README.rst.github/ISSUE_TEMPLATE.mddocs/Makefileexamples/app/myapp.py.github/ISSUE_TEMPLATE/Bug-Report.mddocker/docs/Dockerfiledocs/_ext/celerydocs.pyexamples/celery_http_gateway/README.rst.github/ISSUE_TEMPLATE/Documentation-Bug-Report.mddocs/changelog_formatter.pyexamples/celery_http_gateway/__init__.py.github/ISSUE_TEMPLATE/Enhancement.mddocs/conf.pyexamples/celery_http_gateway/manage.py.github/ISSUE_TEMPLATE/Feature-Request.mddocs/includes/installation.txtexamples/celery_http_gateway/settings.py.github/ISSUE_TEMPLATE/Major-Version-Release-Checklist.mdSECURITY.mddocs/includes/introduction.txtexamples/celery_http_gateway/tasks.py.github/ISSUE_TEMPLATE/Minor-Version-Release-Checklist.mddocs/includes/resources.txtexamples/celery_http_gateway/urls.py.github/ISSUE_TEMPLATE/Patch-Version-Release-Checklist.mddocs/sec/CELERYSA-0001.txtexamples/django/README.rstdocs/sec/CELERYSA-0002.txtexamples/django/demoapp/__init__.py.github/PULL_REQUEST_TEMPLATE.mddocs/sec/CELERYSA-0003.txtexamples/django/demoapp/migrations/0001_initial.py.github/copilot-instructions.mddocs/spelling_wordlist.txtexamples/django/demoapp/migrations/__init__.pydocs/templates/readme.txtexamples/django/demoapp/models.pyexamples/django/demoapp/tasks.pyexamples/django/demoapp/views.pyexamples/django/manage.pyexamples/django/proj/__init__.pyexamples/django/proj/celery.pyexamples/django/proj/settings.pyexamples/django/proj/urls.pyexamples/django/proj/wsgi.pyexamples/django/requirements.txtexamples/eventlet/README.rstexamples/eventlet/bulk_task_producer.pyexamples/eventlet/celeryconfig.pyexamples/eventlet/tasks.pyexamples/eventlet/webcrawler.pyexamples/gevent/README.rstexamples/gevent/celeryconfig.pyexamples/gevent/tasks.pyexamples/next-steps/proj/__init__.pyexamples/next-steps/proj/celery.pyexamples/next-steps/proj/tasks.pyexamples/next-steps/setup.pyexamples/periodic-tasks/myapp.pyexamples/pydantic/__init__.pyexamples/pydantic/tasks.pyexamples/quorum-queues/declare_queue.pyexamples/quorum-queues/myapp.pyexamples/quorum-queues/setup_cluster.shexamples/quorum-queues/test_cluster.shexamples/resultgraph/tasks.pyexamples/security/mysecureapp.pyexamples/stamping/config.pyexamples/stamping/examples.pyexamples/stamping/myapp.pyexamples/stamping/revoke_example.pyexamples/stamping/tasks.pyexamples/stamping/visitors.pyexamples/tutorial/tasks.py
Source
celery/app/__init__.pycelery/app/amqp.pycelery/app/annotations.pycelery/app/autoretry.pycelery/app/backends.pycelery/app/base.pycelery/app/builtins.pycelery/app/control.pycelery/app/defaults.pycelery/app/events.pycelery/app/log.pycelery/app/registry.pycelery/app/routes.pycelery/app/task.pycelery/app/trace.pycelery/app/utils.pyt/unit/app/__init__.pyt/unit/app/test_amqp.pyt/unit/app/test_annotations.pyt/unit/app/test_app.pyt/unit/app/test_backends.pyt/unit/app/test_beat.pyt/unit/app/test_builtins.pyt/unit/app/test_celery.pyt/unit/app/test_control.pyt/unit/app/test_defaults.pyt/unit/app/test_exceptions.pyt/unit/app/test_loaders.pyt/unit/app/test_log.pyt/unit/app/test_preload_cli.pyt/unit/app/test_registry.pyt/unit/app/test_routes.pyt/unit/app/test_schedules.pyt/unit/app/test_trace.pyt/unit/app/test_utils.py
Configuration
.github/FUNDING.ymldocker/Dockerfilepyproject.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.yamlcelery/__init__.pyextra/release/attribution.pyhelm-chart/Chart.yamlrequirements/README.rstt/__init__.py.readthedocs.yamlcelery/__main__.pydocker/docker-compose.ymlextra/release/gen-cert.shhelm-chart/README.rstrequirements/constraints.txtt/benchmarks/bench_worker.pyCONTRIBUTORS.txtcelery/_state.pyextra/release/sphinx2rst_config.pyhelm-chart/templates/configmap.yamlrequirements/default.txtt/integration/__init__.pyLICENSEdocker/scripts/create-linux-user.shextra/supervisord/celery.shhelm-chart/templates/deployment.yamlrequirements/deps/mock.txtt/integration/conftest.pyMakefiledocker/scripts/install-couchbase.shextra/supervisord/celerybeat.confhelm-chart/templates/secret.yamlrequirements/dev.txtt/integration/django_settings.pyREADME.rstdocker/scripts/install-pyenv.shextra/supervisord/celeryd.confhelm-chart/templates/serviceaccount.yamlrequirements/docs.txtt/integration/serialization_config.pyextra/supervisord/supervisord.confhelm-chart/values.yamlrequirements/extras/arangodb.txtt/integration/tasks.pybandit.jsonextra/systemd/celery.confrequirements/extras/auth.txtt/integration/test_backend.pyrequirements/extras/azureblockblob.txtt/integration/test_canvas.pysetup.pyrequirements/extras/brotli.txtt/integration/test_connection_recovery.pytox.inirequirements/extras/cassandra.txtt/integration/test_database_backend.pyrequirements/extras/consul.txtt/integration/test_inspect.pyrequirements/extras/cosmosdbsql.txtt/integration/test_loader.pyrequirements/extras/couchbase.txtt/integration/test_mem_leak_in_exception_handling.pyrequirements/extras/couchdb.txtt/integration/test_security.pyrequirements/extras/django.txtt/integration/test_serialization.pyrequirements/extras/dynamodb.txtt/integration/test_tasks.pyrequirements/extras/elasticsearch.txtt/integration/test_worker.pyrequirements/extras/eventlet.txtt/integration/worker_config.pycelery/apps/__init__.pyrequirements/extras/gcpubsub.txtt/skip.pycelery/apps/beat.pyrequirements/extras/gcs.txtt/smoke/__init__.pycelery/apps/multi.pyrequirements/extras/gevent.txtt/smoke/conftest.pycelery/apps/worker.pyrequirements/extras/librabbitmq.txtt/smoke/operations/__init__.pycelery/backends/__init__.pyrequirements/extras/memcache.txtt/smoke/operations/task_termination.pycelery/backends/arangodb.pyrequirements/extras/mongodb.txtt/smoke/operations/worker_kill.pycelery/backends/asynchronous.pyrequirements/extras/msgpack.txtt/smoke/operations/worker_restart.pycelery/backends/azureblockblob.pyrequirements/extras/pydantic.txtt/smoke/redis.confcelery/backends/base.pyrequirements/extras/pymemcache.txtt/smoke/signals.pycelery/backends/cache.pyrequirements/extras/pyro.txtt/smoke/tasks.pycelery/backends/cassandra.py