Update queue usage
@@ -165,9 +165,6 @@ class EventsCeleryTasks(object):
EVENTS_HANDLE_JOB_STATUSES = 'events_handle_job_statuses'
EVENTS_HANDLE_PLUGIN_JOB_STATUSES = 'events_handle_plugin_job_statuses'
EVENTS_HANDLE_BUILD_JOB_STATUSES = 'events_handle_build_job_statuses'
- EVENTS_HANDLE_LOGS_EXPERIMENT_JOB = 'events_handle_logs_experiment_job'
- EVENTS_HANDLE_LOGS_JOB = 'events_handle_logs_job'
- EVENTS_HANDLE_LOGS_BUILD_JOB = 'events_handle_logs_build_job'
class LogsCeleryTasks(object):
@@ -449,6 +446,10 @@ CELERY_TASK_ROUTES = {
EventsCeleryTasks.EVENTS_HANDLE_BUILD_JOB_STATUSES:
{'queue': CeleryQueues.EVENTS_JOB_STATUSES},
+ # Logs health
+ LogsCeleryTasks.LOGS_HEALTH:
+ {'queue': CeleryQueues.LOGS_HEALTH},
+
# Logs ops
LogsCeleryTasks.LOGS_HANDLE_EXPERIMENT_JOB:
{'queue': CeleryQueues.LOGS_SIDECARS},
