def METHOD_NAME(sessionId, data, **kwargs):
    from cuml.cluster.dbscan_mg import DBSCANMG as cumlDBSCAN
    handle = get_raft_comm_state(sessionId, get_worker())["handle"]
    return cumlDBSCAN(handle=handle, **kwargs).fit(
        data, out_dtype=out_dtype
    )