Tell worker(s) to send task-related events.
(state)
| 343 | |
| 344 | @control_command() |
| 345 | def enable_events(state): |
| 346 | """Tell worker(s) to send task-related events.""" |
| 347 | dispatcher = state.consumer.event_dispatcher |
| 348 | if dispatcher.groups and 'task' not in dispatcher.groups: |
| 349 | dispatcher.groups.add('task') |
| 350 | logger.info('Events of group {task} enabled by remote.') |
| 351 | return ok('task events enabled') |
| 352 | return ok('task events already enabled') |
| 353 | |
| 354 | |
| 355 | @control_command() |