Tell worker(s) to stop sending task-related events.
(state)
| 354 | |
| 355 | @control_command() |
| 356 | def disable_events(state): |
| 357 | """Tell worker(s) to stop sending task-related events.""" |
| 358 | dispatcher = state.consumer.event_dispatcher |
| 359 | if 'task' in dispatcher.groups: |
| 360 | dispatcher.groups.discard('task') |
| 361 | logger.info('Events of group {task} disabled by remote.') |
| 362 | return ok('task events disabled') |
| 363 | return ok('task events already disabled') |
| 364 | |
| 365 | |
| 366 | @control_command() |