Function control

celery/bin/control.py:236–262

Send the COMMAND control command to the workers. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports.

(ctx, command, timeout, destination, json)

@click.pass_context
@handle_preload_options
def control(ctx, command, timeout, destination, json):
    """Send the COMMAND control command to the workers.

    Availability: RabbitMQ (AMQP), Redis, and MongoDB transports.
    """
    _verify_command_name('control', command)
    callback = None if json else partial(_say_remote_command_reply, ctx,
                                         show_reply=True)
    args = ctx.args
    arguments = _compile_arguments(command, args)
    try:
        replies = ctx.obj.app.control.broadcast(command, timeout=timeout,
                                                destination=destination,
                                                callback=callback,
                                                reply=True,
                                                arguments=arguments)
    except Exception as exc:
        handle_remote_command_error(f'control {command}', exc)

    if not replies:
        raise CeleryCommandException(
            message='No nodes replied within time constraint',
            exit_code=EX_UNAVAILABLE
        )

    if json:
        ctx.obj.echo(dumps(replies))