def METHOD_NAME(
    ocm_api: OCMBaseClient, cluster_id: str
) -> tuple[Optional[str], Optional[str]]:
    schedules = get_control_plane_upgrade_policies(ocm_api, cluster_id)
    schedule = [s for s in schedules if s["state"]["value"] == "started"]
    if not schedule:
        return None, None
    if len(schedule) > 1:
        logging.error(f"[{cluster_id}] More than one schedule started.")
    return schedule[0]["next_run"], schedule[0]["version"]