def METHOD_NAME(ceph_cluster, num, io):
    """Run IO on newly added namespace.
    Args:
        io: io args
        num: Current Namespace number
        ceph_cluster: Ceph cluster
    """
    json_format = {"output-format": "json"}
    LOG.info(io)
    client = get_node_by_id(ceph_cluster, io["node"])
    initiator = Initiator(client)
    # List NVMe targets.
    targets, _ = initiator.list(**json_format)
    data = json.loads(targets)
    device_path = next(
        (
            device["DevicePath"]
            for device in data["Devices"]
            if device["NameSpace"] == num
        ),
        None,
    )
    LOG.debug(device_path)
    if device_path is None:
        raise Exception("nvme volume not found")
    else:
        io_args = {
            "device_name": device_path,
            "client_node": client,
            "run_time": "10",
            "long_running": True,
            "io_type": io["io_type"],
            "cmd_timeout": "notimeout",
        }
        result = run_fio(**io_args)
        if result == 1:
            raise Exception("FIO failure")