merge upstream main
This commit is contained in:
@@ -1,21 +1,28 @@
|
||||
import numpy as np
|
||||
from qibo import hamiltonians
|
||||
from qibo.backends import NumpyBackend
|
||||
from qibo.config import raise_error
|
||||
from qibo.result import QuantumState
|
||||
|
||||
from qibotn.backends.abstract import QibotnBackend
|
||||
|
||||
CUDA_TYPES = {}
|
||||
from qibotn.result import TensorNetworkResult
|
||||
|
||||
|
||||
class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
# CI does not test for GPU
|
||||
"""Creates CuQuantum backend for QiboTN."""
|
||||
|
||||
def __init__(self, runcard):
|
||||
def __init__(self, runcard=None):
|
||||
super().__init__()
|
||||
from cuquantum import cutensornet as cutn # pylint: disable=import-error
|
||||
from cuquantum import __version__ # pylint: disable=import-error
|
||||
|
||||
self.name = "qibotn"
|
||||
self.platform = "cutensornet"
|
||||
self.versions["cuquantum"] = __version__
|
||||
self.supports_multigpu = True
|
||||
self.configure_tn_simulation(runcard)
|
||||
|
||||
def configure_tn_simulation(self, runcard):
|
||||
self.rank = None
|
||||
if runcard is not None:
|
||||
self.MPI_enabled = runcard.get("MPI_enabled", False)
|
||||
self.NCCL_enabled = runcard.get("NCCL_enabled", False)
|
||||
@@ -23,15 +30,17 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
expectation_enabled_value = runcard.get("expectation_enabled")
|
||||
if expectation_enabled_value is True:
|
||||
self.expectation_enabled = True
|
||||
self.pauli_string_pattern = "XXXZ"
|
||||
self.observable = None
|
||||
elif expectation_enabled_value is False:
|
||||
self.expectation_enabled = False
|
||||
elif isinstance(expectation_enabled_value, dict):
|
||||
self.expectation_enabled = True
|
||||
expectation_enabled_dict = runcard.get("expectation_enabled", {})
|
||||
self.pauli_string_pattern = expectation_enabled_dict.get(
|
||||
"pauli_string_pattern", None
|
||||
)
|
||||
self.observable = runcard.get("expectation_enabled", {})
|
||||
elif isinstance(
|
||||
expectation_enabled_value, hamiltonians.SymbolicHamiltonian
|
||||
):
|
||||
self.expectation_enabled = True
|
||||
self.observable = expectation_enabled_value
|
||||
else:
|
||||
raise TypeError("expectation_enabled has an unexpected type")
|
||||
|
||||
@@ -59,44 +68,6 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
self.NCCL_enabled = False
|
||||
self.expectation_enabled = False
|
||||
|
||||
self.name = "qibotn"
|
||||
self.cuquantum = cuquantum
|
||||
self.cutn = cutn
|
||||
self.platform = "cutensornet"
|
||||
self.versions["cuquantum"] = self.cuquantum.__version__
|
||||
self.supports_multigpu = True
|
||||
self.handle = self.cutn.create()
|
||||
|
||||
global CUDA_TYPES
|
||||
CUDA_TYPES = {
|
||||
"complex64": (
|
||||
self.cuquantum.cudaDataType.CUDA_C_32F,
|
||||
self.cuquantum.ComputeType.COMPUTE_32F,
|
||||
),
|
||||
"complex128": (
|
||||
self.cuquantum.cudaDataType.CUDA_C_64F,
|
||||
self.cuquantum.ComputeType.COMPUTE_64F,
|
||||
),
|
||||
}
|
||||
|
||||
def __del__(self):
|
||||
if hasattr(self, "cutn"):
|
||||
self.cutn.destroy(self.handle)
|
||||
|
||||
def cuda_type(self, dtype="complex64"):
|
||||
"""Get CUDA Type.
|
||||
|
||||
Parameters:
|
||||
dtype (str, optional): Either single ("complex64") or double (complex128) precision. Defaults to "complex64".
|
||||
|
||||
Returns:
|
||||
CUDA Type: tuple of cuquantum.cudaDataType and cuquantum.ComputeType
|
||||
"""
|
||||
if dtype in CUDA_TYPES:
|
||||
return CUDA_TYPES[dtype]
|
||||
else:
|
||||
raise TypeError("Type can be either complex64 or complex128")
|
||||
|
||||
def execute_circuit(
|
||||
self, circuit, initial_state=None, nshots=None, return_array=False
|
||||
): # pragma: no cover
|
||||
@@ -136,8 +107,8 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
and self.NCCL_enabled == False
|
||||
and self.expectation_enabled == False
|
||||
):
|
||||
state, rank = eval.dense_vector_tn_MPI(circuit, self.dtype, 32)
|
||||
if rank > 0:
|
||||
state, self.rank = eval.dense_vector_tn_MPI(circuit, self.dtype, 32)
|
||||
if self.rank > 0:
|
||||
state = np.array(0)
|
||||
elif (
|
||||
self.MPI_enabled == False
|
||||
@@ -145,8 +116,8 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
and self.NCCL_enabled == True
|
||||
and self.expectation_enabled == False
|
||||
):
|
||||
state, rank = eval.dense_vector_tn_nccl(circuit, self.dtype, 32)
|
||||
if rank > 0:
|
||||
state, self.rank = eval.dense_vector_tn_nccl(circuit, self.dtype, 32)
|
||||
if self.rank > 0:
|
||||
state = np.array(0)
|
||||
elif (
|
||||
self.MPI_enabled == False
|
||||
@@ -154,19 +125,17 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
and self.NCCL_enabled == False
|
||||
and self.expectation_enabled == True
|
||||
):
|
||||
state = eval.expectation_pauli_tn(
|
||||
circuit, self.dtype, self.pauli_string_pattern
|
||||
)
|
||||
state = eval.expectation_tn(circuit, self.dtype, self.observable)
|
||||
elif (
|
||||
self.MPI_enabled == True
|
||||
and self.MPS_enabled == False
|
||||
and self.NCCL_enabled == False
|
||||
and self.expectation_enabled == True
|
||||
):
|
||||
state, rank = eval.expectation_pauli_tn_MPI(
|
||||
circuit, self.dtype, self.pauli_string_pattern, 32
|
||||
state, self.rank = eval.expectation_tn_MPI(
|
||||
circuit, self.dtype, self.observable, 32
|
||||
)
|
||||
if rank > 0:
|
||||
if self.rank > 0:
|
||||
state = np.array(0)
|
||||
elif (
|
||||
self.MPI_enabled == False
|
||||
@@ -174,15 +143,27 @@ class CuTensorNet(QibotnBackend, NumpyBackend): # pragma: no cover
|
||||
and self.NCCL_enabled == True
|
||||
and self.expectation_enabled == True
|
||||
):
|
||||
state, rank = eval.expectation_pauli_tn_nccl(
|
||||
circuit, self.dtype, self.pauli_string_pattern, 32
|
||||
state, self.rank = eval.expectation_tn_nccl(
|
||||
circuit, self.dtype, self.observable, 32
|
||||
)
|
||||
if rank > 0:
|
||||
if self.rank > 0:
|
||||
state = np.array(0)
|
||||
else:
|
||||
raise_error(NotImplementedError, "Compute type not supported.")
|
||||
|
||||
if return_array:
|
||||
return state.flatten()
|
||||
if self.expectation_enabled:
|
||||
return state.flatten().real
|
||||
else:
|
||||
return QuantumState(state.flatten())
|
||||
if return_array:
|
||||
statevector = state.flatten()
|
||||
else:
|
||||
statevector = state
|
||||
|
||||
return TensorNetworkResult(
|
||||
nqubits=circuit.nqubits,
|
||||
backend=self,
|
||||
measures=None,
|
||||
measured_probabilities=None,
|
||||
prob_type=None,
|
||||
statevector=statevector,
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user