Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/celery_backend/config.py
| Show First 20 Lines • Show All 280 Lines • ▼ Show 20 Lines | CELERY_DEFAULT_CONFIG = dict( | ||||
| # tombstones will be deleted. None means to never expire results. | # tombstones will be deleted. None means to never expire results. | ||||
| result_expires=None, | result_expires=None, | ||||
| # A string identifying the default serialization method to use. Can | # A string identifying the default serialization method to use. Can | ||||
| # be json (default), pickle, yaml, msgpack, or any custom | # be json (default), pickle, yaml, msgpack, or any custom | ||||
| # serialization methods that have been registered with | # serialization methods that have been registered with | ||||
| task_serializer="msgpack", | task_serializer="msgpack", | ||||
| # Result serialization format | # Result serialization format | ||||
| result_serializer="msgpack", | result_serializer="msgpack", | ||||
| # Late ack means the task messages will be acknowledged after the task has | # Acknowledge tasks as soon as they're received. We can do this as we have | ||||
| # been executed, not just before, which is the default behavior. | # external monitoring to decide if we need to retry tasks. | ||||
| task_acks_late=True, | task_acks_late=False, | ||||
| # A string identifying the default serialization method to use. | # A string identifying the default serialization method to use. | ||||
| # Can be pickle (default), json, yaml, msgpack or any custom serialization | # Can be pickle (default), json, yaml, msgpack or any custom serialization | ||||
| # methods that have been registered with kombu.serialization.registry | # methods that have been registered with kombu.serialization.registry | ||||
| accept_content=["msgpack", "json"], | accept_content=["msgpack", "json"], | ||||
| # If True the task will report its status as “started” | # If True the task will report its status as “started” | ||||
| # when the task is executed by a worker. | # when the task is executed by a worker. | ||||
| task_track_started=True, | task_track_started=True, | ||||
| # Default compression used for task messages. Can be gzip, bzip2 | # Default compression used for task messages. Can be gzip, bzip2 | ||||
| ▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines | |||||