def METHOD_NAME(ceph_cluster, osd_id, rados_obj, host, dev_path):
    try:
        global stop_flag
        add_osd(ceph_cluster, host.hostname, dev_path, osd_id)
        method_should_succeed(wait_for_device, host, osd_id, action="add")
        method_should_succeed(wait_for_clean_pg_sets, rados_obj)
        stop_flag = True
    except Exception as e:
        log.error(e)
        log.error(traceback.format_exc())
        raise CommandFailed("Adding osd failed")