From e8c331392210054748f349193e24f463ea593377 Mon Sep 17 00:00:00 2001
From: superstar54 <xingwang1991@gmail.com>
Date: Sat, 30 Nov 2024 22:16:48 +0100
Subject: [PATCH] Remove unused code in utils

---
 aiida_workgraph/utils/__init__.py | 51 ++-----------------------------
 1 file changed, 2 insertions(+), 49 deletions(-)

diff --git a/aiida_workgraph/utils/__init__.py b/aiida_workgraph/utils/__init__.py
index b7d5ec40..16e11768 100644
--- a/aiida_workgraph/utils/__init__.py
+++ b/aiida_workgraph/utils/__init__.py
@@ -212,20 +212,9 @@ def update_nested_dict(d: Optional[Dict[str, Any]], key: str, value: Any) -> Non
     return current
 
 
-def is_empty(value: Any) -> bool:
-    """Check if the provided value is an empty collection."""
-    import numpy as np
-
-    if isinstance(value, np.ndarray):
-        return value.size == 0
-    elif isinstance(value, (dict, list, set, tuple)):
-        return not value
-    return False
-
-
 def update_nested_dict_with_special_keys(data: Dict[str, Any]) -> Dict[str, Any]:
-    """Remove None and empty value"""
-    # data = {k: v for k, v in data.items() if v is not None and not is_empty(v)}
+    """Update the nested dictionary with special keys like "base.pw.parameters"."""
+    # Remove None
     data = {k: v for k, v in data.items() if v is not None}
     #
     special_keys = [k for k in data.keys() if "." in k]
@@ -306,34 +295,6 @@ def generate_node_graph(
     return g
 
 
-def build_task_link(wgdata: Dict[str, Any]) -> None:
-    """Create links for tasks.
-    Create the links for task inputs using:
-    1) workgraph links
-    2) if it is a graph builder graph, expose the group inputs and outputs
-    sockets.
-    """
-    # reset task input links
-    for name, task in wgdata["tasks"].items():
-        for input in task["inputs"]:
-            input["links"] = []
-        for output in task["outputs"]:
-            output["links"] = []
-    for link in wgdata["links"]:
-        to_socket = [
-            socket
-            for socket in wgdata["tasks"][link["to_node"]]["inputs"]
-            if socket["name"] == link["to_socket"]
-        ][0]
-        from_socket = [
-            socket
-            for socket in wgdata["tasks"][link["from_node"]]["outputs"]
-            if socket["name"] == link["from_socket"]
-        ][0]
-        to_socket["links"].append(link)
-        from_socket["links"].append(link)
-
-
 def get_dict_from_builder(builder: Any) -> Dict:
     """Transform builder to pure dict."""
     from aiida.engine.processes.builder import ProcessBuilderNamespace
@@ -344,14 +305,6 @@ def get_dict_from_builder(builder: Any) -> Dict:
         return builder
 
 
-def serialize_workgraph_data(wgdata: Dict[str, Any]) -> Dict[str, Any]:
-    from aiida.orm.utils.serialize import serialize
-
-    for name, task in wgdata["tasks"].items():
-        wgdata["tasks"][name] = serialize(task)
-    wgdata["error_handlers"] = serialize(wgdata["error_handlers"])
-
-
 def get_workgraph_data(process: Union[int, orm.Node]) -> Optional[Dict[str, Any]]:
     """Get the workgraph data from the process node."""
     from aiida.orm.utils.serialize import deserialize_unsafe