celery.worker.strategy

Task execution strategy (optimization).

celery.worker.strategy.default(task, app, consumer, info=<bound method Logger.info of <Logger celery.worker.strategy (WARNING)>>, error=<bound method Logger.error of <Logger celery.worker.strategy (WARNING)>>, task_reserved=<function task_reserved>, to_system_tz=<bound method _Zone.to_system of <celery.utils.time._Zone object>>, bytes=<class 'bytes'>, proto1_to_proto2=<function proto1_to_proto2>): Default task execution strategy.

Note

Strategies are here as an optimization, so sadly it’s not very easy to override.

Copyright © 2017-2026 Asif Saif Uddin, core team & contributors. All rights reserved.
Celery is licensed under The BSD License (3 Clause, also known as the new BSD license). The license is an OSI approved Open Source license and is GPL-compatible.
https://docs.celeryq.dev/en/stable/reference/celery.worker.strategy.html