Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions docs/source/_rst/_code.rst
Original file line number Diff line number Diff line change
Expand Up @@ -68,15 +68,19 @@ Solvers
SolverInterface <solver/solver_interface.rst>
SingleSolverInterface <solver/single_solver_interface.rst>
MultiSolverInterface <solver/multi_solver_interface.rst>
SupervisedSolverInterface <solver/supervised_solver/supervised_solver_interface>
DeepEnsembleSolverInterface <solver/ensemble_solver/ensemble_solver_interface>
PINNInterface <solver/physics_informed_solver/pinn_interface.rst>
PINN <solver/physics_informed_solver/pinn.rst>
GradientPINN <solver/physics_informed_solver/gradient_pinn.rst>
CausalPINN <solver/physics_informed_solver/causal_pinn.rst>
CompetitivePINN <solver/physics_informed_solver/competitive_pinn.rst>
SelfAdaptivePINN <solver/physics_informed_solver/self_adaptive_pinn.rst>
RBAPINN <solver/physics_informed_solver/rba_pinn.rst>
SupervisedSolver <solver/supervised.rst>
ReducedOrderModelSolver <solver/reduced_order_model.rst>
DeepEnsemblePINN <solver/ensemble_solver/ensemble_pinn>
SupervisedSolver <solver/supervised_solver/supervised.rst>
DeepEnsembleSupervisedSolver <solver/ensemble_solver/ensemble_supervised>
ReducedOrderModelSolver <solver/supervised_solver/reduced_order_model.rst>
GAROM <solver/garom.rst>


Expand Down
8 changes: 8 additions & 0 deletions docs/source/_rst/solver/ensemble_solver/ensemble_pinn.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
DeepEnsemblePINN
==================
.. currentmodule:: pina.solver.ensemble_solver.ensemble_pinn

.. autoclass:: DeepEnsemblePINN
:show-inheritance:
:members:

Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
DeepEnsembleSolverInterface
=============================
.. currentmodule:: pina.solver.ensemble_solver.ensemble_solver_interface

.. autoclass:: DeepEnsembleSolverInterface
:show-inheritance:
:members:

Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
DeepEnsembleSupervisedSolver
=============================
.. currentmodule:: pina.solver.ensemble_solver.ensemble_supervised

.. autoclass:: DeepEnsembleSupervisedSolver
:show-inheritance:
:members:

Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
ReducedOrderModelSolver
==========================
.. currentmodule:: pina.solver.reduced_order_model
.. currentmodule:: pina.solver.supervised_solver.reduced_order_model

.. autoclass:: ReducedOrderModelSolver
:members:
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
SupervisedSolver
===================
.. currentmodule:: pina.solver.supervised
.. currentmodule:: pina.solver.supervised_solver.supervised

.. autoclass:: SupervisedSolver
:members:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
SupervisedSolverInterface
==========================
.. currentmodule:: pina.solver.supervised_solver.supervised_solver_interface

.. autoclass:: SupervisedSolverInterface
:show-inheritance:
:members:

26 changes: 23 additions & 3 deletions pina/solver/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,13 +11,33 @@
"CompetitivePINN",
"SelfAdaptivePINN",
"RBAPINN",
"SupervisedSolverInterface",
"SupervisedSolver",
"ReducedOrderModelSolver",
"DeepEnsembleSolverInterface",
"DeepEnsembleSupervisedSolver",
"DeepEnsemblePINN",
"GAROM",
]

from .solver import SolverInterface, SingleSolverInterface, MultiSolverInterface
from .physics_informed_solver import *
from .supervised import SupervisedSolver
from .reduced_order_model import ReducedOrderModelSolver
from .physics_informed_solver import (
PINNInterface,
PINN,
GradientPINN,
CausalPINN,
CompetitivePINN,
SelfAdaptivePINN,
RBAPINN,
)
from .supervised_solver import (
SupervisedSolverInterface,
SupervisedSolver,
ReducedOrderModelSolver,
)
from .ensemble_solver import (
DeepEnsembleSolverInterface,
DeepEnsembleSupervisedSolver,
DeepEnsemblePINN,
)
from .garom import GAROM
11 changes: 11 additions & 0 deletions pina/solver/ensemble_solver/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
"""Module for the Ensemble solver classes."""

__all__ = [
"DeepEnsembleSolverInterface",
"DeepEnsembleSupervisedSolver",
"DeepEnsemblePINN",
]

from .ensemble_solver_interface import DeepEnsembleSolverInterface
from .ensemble_supervised import DeepEnsembleSupervisedSolver
from .ensemble_pinn import DeepEnsemblePINN
170 changes: 170 additions & 0 deletions pina/solver/ensemble_solver/ensemble_pinn.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,170 @@
"""Module for the DeepEnsemble physics solver."""

import torch

from .ensemble_solver_interface import DeepEnsembleSolverInterface
from ..physics_informed_solver import PINNInterface
from ...problem import InverseProblem


class DeepEnsemblePINN(PINNInterface, DeepEnsembleSolverInterface):
r"""
Deep Ensemble Physics Informed Solver class. This class implements a
Deep Ensemble for Physics Informed Neural Networks using user
specified ``model``s to solve a specific ``problem``.

An ensemble model is constructed by combining multiple models that solve
the same type of problem. Mathematically, this creates an implicit
distribution :math:`p(\mathbf{u} \mid \mathbf{s})` over the possible
outputs :math:`\mathbf{u}`, given the original input :math:`\mathbf{s}`.
The models :math:`\mathcal{M}_{i\in (1,\dots,r)}` in
the ensemble work collaboratively to capture different
aspects of the data or task, with each model contributing a distinct
prediction :math:`\mathbf{y}_{i}=\mathcal{M}_i(\mathbf{u} \mid \mathbf{s})`.
By aggregating these predictions, the ensemble
model can achieve greater robustness and accuracy compared to individual
models, leveraging the diversity of the models to reduce overfitting and
improve generalization. Furthemore, statistical metrics can
be computed, e.g. the ensemble mean and variance:

.. math::
\mathbf{\mu} = \frac{1}{N}\sum_{i=1}^r \mathbf{y}_{i}

.. math::
\mathbf{\sigma^2} = \frac{1}{N}\sum_{i=1}^r
(\mathbf{y}_{i} - \mathbf{\mu})^2

During training the PINN loss is minimized by each ensemble model:

.. math::
\mathcal{L}_{\rm{problem}} = \frac{1}{N}\sum_{i=1}^4
\mathcal{L}(\mathcal{A}[\mathbf{u}](\mathbf{x}_i)) +
\frac{1}{N}\sum_{i=1}^N
\mathcal{L}(\mathcal{B}[\mathbf{u}](\mathbf{x}_i)),

for the differential system:

.. math::

\begin{cases}
\mathcal{A}[\mathbf{u}](\mathbf{x})=0\quad,\mathbf{x}\in\Omega\\
\mathcal{B}[\mathbf{u}](\mathbf{x})=0\quad,
\mathbf{x}\in\partial\Omega
\end{cases}

:math:`\mathcal{L}` indicates a specific loss function, typically the MSE:

.. math::
\mathcal{L}(v) = \| v \|^2_2.

.. seealso::

**Original reference**: Zou, Z., Wang, Z., & Karniadakis, G. E. (2025).
*Learning and discovering multiple solutions using physics-informed
neural networks with random initialization and deep ensemble*.
DOI: `arXiv:2503.06320 <https://arxiv.org/abs/2503.06320>`_.

.. warning::
This solver does not work with inverse problem. Hence in the ``problem``
definition must not inherit from
:class:`~pina.problem.inverse_problem.InverseProblem`.
"""

def __init__(
self,
problem,
models,
loss=None,
optimizers=None,
schedulers=None,
weighting=None,
ensemble_dim=0,
):
"""
Initialization of the :class:`DeepEnsemblePINN` class.

:param AbstractProblem problem: The problem to be solved.
:param torch.nn.Module models: The neural network models to be used.
:param torch.nn.Module loss: The loss function to be minimized.
If ``None``, the :class:`torch.nn.MSELoss` loss is used.
Default is ``None``.
:param Optimizer optimizer: The optimizer to be used.
If ``None``, the :class:`torch.optim.Adam` optimizer is used.
Default is ``None``.
:param Scheduler scheduler: Learning rate scheduler.
If ``None``, the :class:`torch.optim.lr_scheduler.ConstantLR`
scheduler is used. Default is ``None``.
:param WeightingInterface weighting: The weighting schema to be used.
If ``None``, no weighting schema is used. Default is ``None``.
:param int ensemble_dim: The dimension along which the ensemble
outputs are stacked. Default is 0.
Comment thread
dario-coscia marked this conversation as resolved.
:raises NotImplementedError: If an inverse problem is passed.
"""
if isinstance(problem, InverseProblem):
raise NotImplementedError(
"DeepEnsemblePINN can not be used to solve inverse problems."
)
super().__init__(
problem=problem,
models=models,
loss=loss,
optimizers=optimizers,
schedulers=schedulers,
weighting=weighting,
ensemble_dim=ensemble_dim,
)

def loss_data(self, input, target):
"""
Compute the data loss for the ensemble PINN solver by evaluating
the loss between the network's output and the true solution for each
model. This method should not be overridden, if not intentionally.

:param input: The input to the neural network.
:type input: LabelTensor | torch.Tensor | Graph | Data
:param target: The target to compare with the network's output.
:type target: LabelTensor | torch.Tensor | Graph | Data
:return: The supervised loss, averaged over the number of observations.
:rtype: torch.Tensor
"""
predictions = self.forward(input)
loss = sum(
self._loss_fn(predictions[idx], target)
for idx in range(self.num_ensemble)
)
return loss / self.num_ensemble

def loss_phys(self, samples, equation):
"""
Computes the physics loss for the ensemble PINN solver by evaluating
the loss between the network's output and the true solution for each
model. This method should not be overridden, if not intentionally.

:param LabelTensor samples: The samples to evaluate the physics loss.
:param EquationInterface equation: The governing equation.
:return: The computed physics loss.
:rtype: LabelTensor
"""
return self._residual_loss(samples, equation)

def _residual_loss(self, samples, equation):
"""
Computes the physics loss for the physics-informed solver based on the
provided samples and equation. This method should never be overridden
by the user, if not intentionally,
since it is used internally to compute validation loss. It overrides the
:obj:`~pina.solver.physics_informed_solver.PINNInterface._residual_loss`
method.

:param LabelTensor samples: The samples to evaluate the loss.
:param EquationInterface equation: The governing equation.
:return: The residual loss.
:rtype: torch.Tensor
"""
loss = 0
predictions = self.forward(samples)
for idx in range(self.num_ensemble):
residuals = equation.residual(samples, predictions[idx])
target = torch.zeros_like(residuals, requires_grad=True)
loss = loss + self._loss_fn(residuals, target)
return loss / self.num_ensemble
Loading