@task
def add_user(user, password):
    """Add the user to rabbitmq, if the user already exist the password will be set again
    """
    active_users = rabbitmq_ctl("list_users")
    if user in active_users.split():
        rabbitmq_ctl("change_password", user, password)
    else:
        with settings(warn_only=True):
            rabbitmq_ctl("add_user", user, password)
dataset/ETHPy150Open ebu/radiodns-plugit/Deployment/rabbitmq/rabbitmq_server.py/add_user/original