Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/celery_backend/config.py
| Show First 20 Lines • Show All 248 Lines • ▼ Show 20 Lines | CELERY_DEFAULT_CONFIG = dict( | ||||
| worker_prefetch_multiplier=1, | worker_prefetch_multiplier=1, | ||||
| # Send events | # Send events | ||||
| worker_send_task_events=True, | worker_send_task_events=True, | ||||
| # Do not send useless task_sent events | # Do not send useless task_sent events | ||||
| task_send_sent_event=False, | task_send_sent_event=False, | ||||
| ) | ) | ||||
| # Instantiate the Celery app | # Instantiate the Celery app | ||||
| app = Celery(broker=CONFIG['task_broker']) | app = Celery(broker=CONFIG['task_broker'], | ||||
| task_cls='swh.scheduler.task:SWHTask') | |||||
| app.add_defaults(CELERY_DEFAULT_CONFIG) | app.add_defaults(CELERY_DEFAULT_CONFIG) | ||||
| # XXX for BW compat | # XXX for BW compat | ||||
| Celery.get_queue_length = get_queue_length | Celery.get_queue_length = get_queue_length | ||||