def METHOD_NAME(image_data):
    """
    Perform a /image/import operation on all nodes
    :param image_data: Raw bytes of the OCI image tar file
    """
    try:
        endpoints = get_cluster_agent_endpoints(include_self=True)
    except subprocess.CalledProcessError as e:
        print("Could not query for nodes")
        raise SystemExit(e)
    for node_ep, token in endpoints:
        try:
            print("Pushing OCI images to {}".format(node_ep))
            res = requests.post(
                "https://{}/{}/image/import".format(node_ep, CLUSTER_API_V2),
                data=image_data,
                headers={
                    "x-microk8s-callback-token": token,
                },
                verify=False,
            )
            if res.status_code != 200:
                print("Failed to import images on {}: {}".format(node_ep, res.content.decode()))
        except requests.exceptions.RequestException as e:
            print("Failed to reach {}: {}".format(node_ep, e))