Differential D6410 Diff 23311 swh/scheduler/celery_backend/config.py

Changeset View

Standalone View

swh/scheduler/celery_backend/config.py

Show First 20 Lines • Show All 307 Lines • ▼ Show 20 Lines	CELERY_DEFAULT_CONFIG = dict(
# Result serialization format		# Result serialization format
result_serializer="msgpack",		result_serializer="msgpack",
# Acknowledge tasks as soon as they're received. We can do this as we have		# Acknowledge tasks as soon as they're received. We can do this as we have
# external monitoring to decide if we need to retry tasks.		# external monitoring to decide if we need to retry tasks.
task_acks_late=False,		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", "application/x-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
# (if available), or any custom compression schemes registered		# (if available), or any custom compression schemes registered
# in the Kombu compression registry.		# in the Kombu compression registry.
# result_compression='bzip2',		# result_compression='bzip2',
# task_compression='bzip2',		# task_compression='bzip2',
Show All 39 Lines