WIP full verifciation

pyproject.toml

@@ -51,7 +51,7 @@ aiida-sssp-workflow = "aiida_sssp_workflow.cli:cmd_root"
 "sssp_workflow.convergence.phonon_frequencies" = "aiida_sssp_workflow.workflows.convergence.phonon_frequencies:ConvergencePhononFrequenciesWorkChain"
 "sssp_workflow.convergence.pressure" = "aiida_sssp_workflow.workflows.convergence.pressure:ConvergencePressureWorkChain"
 "sssp_workflow.convergence.bands" = "aiida_sssp_workflow.workflows.convergence.bands:ConvergenceBandsWorkChain"
-"sssp_workflow.verification" = "aiida_sssp_workflow.workflows.verifications:FullVerificationWorkChain"
+"sssp_workflow.verification" = "aiida_sssp_workflow.workflows.verification:FullVerificationWorkChain"
 
 [project.urls]
 Documentation = "https://aiida-sssp-workflow.readthedocs.io/"

src/aiida_sssp_workflow/utils/__init__.py

@@ -36,3 +36,59 @@ def get_default_mpi_options(
         "max_wallclock_seconds": int(max_wallclock_seconds),
         "withmpi": with_mpi,
     }
+
+def serialize_data(data):
+    from aiida.orm import (
+        AbstractCode,
+        BaseType,
+        Data,
+        Dict,
+        KpointsData,
+        List,
+        RemoteData,
+        SinglefileData,
+    )
+    from aiida.plugins import DataFactory
+
+    StructureData = DataFactory("core.structure")
+    UpfData = DataFactory("pseudo.upf")
+
+    if isinstance(data, dict):
+        return {key: serialize_data(value) for key, value in data.items()}
+
+    if isinstance(data, BaseType):
+        return data.value
+
+    if isinstance(data, AbstractCode):
+        return data.full_label
+
+    if isinstance(data, Dict):
+        return data.get_dict()
+
+    if isinstance(data, List):
+        return data.get_list()
+
+    if isinstance(data, StructureData):
+        return data.get_formula()
+
+    if isinstance(data, UpfData):
+        return f"{data.element}<md5={data.md5}>"
+
+    if isinstance(data, RemoteData):
+        # For `RemoteData` we compute the hash of the repository. The value returned by `Node._get_hash` is not
+        # useful since it includes the hash of the absolute filepath and the computer UUID which vary between tests
+        return data.base.repository.hash()
+
+    if isinstance(data, KpointsData):
+        try:
+            return data.get_kpoints().tolist()
+        except AttributeError:
+            return data.get_kpoints_mesh()
+
+    if isinstance(data, SinglefileData):
+        return data.get_content()
+
+    if isinstance(data, Data):
+        return data.base.caching._get_hash()
+
+    return data

src/aiida_sssp_workflow/workflows/convergence/_base.py

@@ -234,21 +234,30 @@ def get_builder(
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
+        configuration: str | None = None,
         clean_workdir: bool = True,
     ) -> ProcessBuilder:
         """Generate builder for the generic convergence workflow"""
         builder = super().get_builder()
         builder.protocol = orm.Str(protocol)
 
+        if configuration is not None:
+            builder.configuration = orm.Str(configuration)
+            configuration_name = configuration
+
+            if ret := is_valid_convergence_configuration(configuration):
+                raise ValueError(ret)
+        else:
+            configuration_name = "default"
+
         # Set the default label and description
         # The default label is set to be the base file name of PP
         # The description include which configuration and which protocol is using.
         builder.metadata.label = (
             pseudo.filename if isinstance(pseudo, UpfData) else pseudo.name
         )
         builder.metadata.description = (
-            f"Run on protocol '{protocol}' and configuration '{configuration}'"
+            f"Run on protocol '{protocol}' and configuration '{configuration_name}'"
         )
 
         if isinstance(pseudo, Path):
@@ -259,11 +268,8 @@ def get_builder(
         if ret := is_valid_cutoff_list(cutoff_list):
             raise ValueError(ret)
 
-        if ret := is_valid_convergence_configuration(configuration):
-            raise ValueError(ret)
 
         builder.cutoff_list = orm.List(list=cutoff_list)
-        builder.configuration = orm.Str(configuration)
         builder.clean_workdir = orm.Bool(clean_workdir)
 
         return builder

src/aiida_sssp_workflow/workflows/convergence/bands.py

@@ -50,8 +50,8 @@ def get_builder(
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
         code: orm.AbstractCode,
+        configuration: str | None = None,
         parallelization: dict | None = None,
         mpi_options: dict | None = None,
         clean_workdir: bool = True,  # default to clean workdir

src/aiida_sssp_workflow/workflows/convergence/caching.py

@@ -52,8 +52,8 @@ def get_builder(
         pseudo: Path,
         protocol: str,
         cutoff_list: list,
-        configuration: str,
         code: orm.AbstractCode,
+        configuration: str | None = None,
         parallelization: dict | None = None,
         mpi_options: dict | None = None,
         clean_workdir: bool = False,

src/aiida_sssp_workflow/workflows/convergence/cohesive_energy.py

@@ -62,8 +62,8 @@ def get_builder(
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
         code: orm.AbstractCode,
+        configuration: str | None = None,
         bulk_parallelization: dict | None = None,
         bulk_mpi_options: dict | None = None,
         atom_parallelization: dict | None = None,

src/aiida_sssp_workflow/workflows/convergence/eos.py

@@ -48,8 +48,8 @@ def get_builder(
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
         code: orm.AbstractCode,
+        configuration: str | None = None,
         parallelization: dict | None = None,
         mpi_options: dict | None = None,
         clean_workdir: bool = True,  # default to clean workdir

src/aiida_sssp_workflow/workflows/convergence/phonon_frequencies.py

@@ -68,9 +68,9 @@ def get_builder(
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
         pw_code: orm.AbstractCode,
         ph_code: orm.AbstractCode,
+        configuration: str | None = None,
         pw_parallelization: dict | None = None,
         ph_settings: dict | None = None,
         pw_mpi_options: dict | None = None,

src/aiida_sssp_workflow/workflows/convergence/pressure.py

@@ -46,11 +46,11 @@ def define(cls, spec):
     @classmethod
     def get_builder(
         cls,
+        code: orm.AbstractCode,
         pseudo: Union[Path, UpfData],
         protocol: str,
         cutoff_list: list,
-        configuration: str,
-        code: orm.AbstractCode,
+        configuration: str | None = None,
         parallelization: dict | None = None,
         mpi_options: dict | None = None,
         clean_workdir: bool = True,  # clean workdir by default