def METHOD_NAME(self):
    """
    Test each storageconsumer's capacity and requested capacity.
    Now only 1Ti value is possible. If more options get added, the test
    will need to get the value from the consumer cluster's config file
    """
    consumer_names = managedservice.get_consumer_names()
    for consumer_name in consumer_names:
        consumer_yaml = ocp.OCP(
            kind="StorageConsumer",
            namespace=config.ENV_DATA["cluster_namespace"],
            resource_name=consumer_name,
        ).get()
        log.info(f"Verifying capacity of {consumer_name}")
        assert consumer_yaml["spec"]["capacity"] in {"1Ti", "1Pi"}
        log.info(f"Verifying granted capacity of {consumer_name}")
        assert (
            consumer_yaml["status"]["grantedCapacity"]
            == consumer_yaml["spec"]["capacity"]
        )