def METHOD_NAME(self, node_type, nodes):
    """
    Test registry workload when backed by OCS and reboot node one by one
    """
    # Get the node list
    node_list = get_nodes(node_type)
    # Pull and push images to registries
    log.info("Pull and push images to registries")
    image_pull_and_push(project_name=self.project_name)
    # Validate image exists in registries path
    validate_image_exists()
    for node in node_list:
        # Reboot node
        log.info(node.name)
        nodes.restart_nodes([node], wait=False)
        # Wait some time after rebooting node
        waiting_time = 40
        log.info(f"Waiting {waiting_time} seconds...")
        time.sleep(waiting_time)
        # Validate all nodes and services are in READY state and up
        retry(
            (
                CommandFailed,
                TimeoutError,
                AssertionError,
                ResourceWrongStatusException,
            ),
            tries=60,
            delay=15,
        )(wait_for_cluster_connectivity)(tries=400)
        retry(
            (
                CommandFailed,
                TimeoutError,
                AssertionError,
                ResourceWrongStatusException,
            ),
            tries=60,
            delay=15,
        )(wait_for_nodes_status)(timeout=900)
    # Validate cluster health ok and all pods are running
    self.sanity_helpers.health_check(tries=40)
    # Validate storage pods are running
    wait_for_storage_pods()
    # Validate image registry pods
    validate_registry_pod_status()
    # Validate image exists in registries path
    validate_image_exists()