Merge pull request #812 from Avaiga/feature/move-name-to-properties-d…

…ict-for-dn feature/#806 move name attribute of dn to properties
Avaiga · Nov 6, 2023 · 63fcfb7 · 63fcfb7
2 parents dd64aac + d51b336
commit 63fcfb7
Show file tree

Hide file tree

Showing 30 changed files with 99 additions and 98 deletions.
diff --git a/src/taipy/core/_entity/_migrate/_utils.py b/src/taipy/core/_entity/_migrate/_utils.py
@@ -190,6 +190,9 @@ def __migrate_datanode(datanode: Dict) -> Dict:
     # Update Scope enum after Pipeline removal
     datanode["scope"] = __update_scope(datanode["scope"])
 
+    # Update move name attribute to properties dictionary
+    datanode["data_node_properties"]["name"] = datanode.pop("name", None)
+
     if "last_edit_date" not in datanode:
         datanode["last_edit_date"] = datanode.get("last_edition_date")
         if "last_edition_date" in datanode:

diff --git a/src/taipy/core/data/_abstract_sql.py b/src/taipy/core/data/_abstract_sql.py
@@ -87,7 +87,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -111,7 +110,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/_data_converter.py b/src/taipy/core/data/_data_converter.py
@@ -144,7 +144,6 @@ def _entity_to_model(cls, data_node: DataNode) -> _DataNodeModel:
             data_node.config_id,
             data_node._scope,
             data_node.storage_type(),
-            properties.pop("name", None) or data_node._name,
             data_node.owner_id,
             list(data_node._parent_ids),
             data_node._last_edit_date.isoformat() if data_node._last_edit_date else None,
@@ -287,7 +286,6 @@ def _model_to_entity(cls, model: _DataNodeModel) -> DataNode:
             config_id=model.config_id,
             scope=model.scope,
             id=model.id,
-            name=model.name,
             owner_id=model.owner_id,
             parent_ids=set(model.parent_ids),
             last_edit_date=datetime.fromisoformat(model.last_edit_date) if model.last_edit_date else None,

diff --git a/src/taipy/core/data/_data_manager.py b/src/taipy/core/data/_data_manager.py
@@ -96,7 +96,6 @@ def __create(
             return cls.__DATA_NODE_CLASS_MAP[storage_type](
                 config_id=data_node_config.id,
                 scope=data_node_config.scope or DataNodeConfig._DEFAULT_SCOPE,
-                name=props.pop(cls.__NAME_KEY, None),
                 validity_period=data_node_config.validity_period,
                 owner_id=owner_id,
                 parent_ids=parent_ids,

diff --git a/src/taipy/core/data/_data_model.py b/src/taipy/core/data/_data_model.py
@@ -31,7 +31,6 @@ class _DataNodeModel(_BaseModel):
         Column("config_id", String),
         Column("scope", Enum(Scope)),
         Column("storage_type", String),
-        Column("name", String),
         Column("owner_id", String),
         Column("parent_ids", JSON),
         Column("last_edit_date", String),
@@ -50,7 +49,6 @@ class _DataNodeModel(_BaseModel):
     config_id: str
     scope: Scope
     storage_type: str
-    name: Optional[str]
     owner_id: Optional[str]
     parent_ids: List[str]
     last_edit_date: Optional[str]
@@ -71,7 +69,6 @@ def from_dict(data: Dict[str, Any]):
             config_id=data["config_id"],
             scope=Scope._from_repr(data["scope"]),
             storage_type=data["storage_type"],
-            name=data.get("name"),
             owner_id=data.get("owner_id"),
             parent_ids=data.get("parent_ids", []),
             last_edit_date=data.get("last_edit_date"),

diff --git a/src/taipy/core/data/csv.py b/src/taipy/core/data/csv.py
@@ -39,7 +39,6 @@ class CSVDataNode(DataNode, _AbstractFileDataNode, _AbstractTabularDataNode):
             Python identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
         last_edit_date (datetime): The date and time of the last modification.
@@ -84,7 +83,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -115,7 +113,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/data_node.py b/src/taipy/core/data/data_node.py
@@ -95,7 +95,6 @@ def __init__(
         config_id,
         scope: Scope = Scope(Scope.SCENARIO),
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -113,7 +112,6 @@ def __init__(
         self._parent_ids = parent_ids or set()
         self._scope = scope
         self._last_edit_date = last_edit_date
-        self._name = name
         self._edit_in_progress = edit_in_progress
         self._version = version or _VersionManagerFactory._build_manager()._get_latest_version()
         self._validity_period = validity_period
@@ -200,14 +198,12 @@ def expiration_date(self) -> datetime:
         return last_edit_date + validity_period if validity_period else last_edit_date
 
     @property  # type: ignore
-    @_self_reload(_MANAGER_NAME)
-    def name(self):
-        return self._name
+    def name(self) -> Optional[str]:
+        return self.properties.get("name")
 
     @name.setter  # type: ignore
-    @_self_setter(_MANAGER_NAME)
     def name(self, val):
-        self._name = val
+        self.properties["name"] = val
 
     @property
     def version(self):

diff --git a/src/taipy/core/data/excel.py b/src/taipy/core/data/excel.py
@@ -43,7 +43,6 @@ class ExcelDataNode(DataNode, _AbstractFileDataNode, _AbstractTabularDataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -89,7 +88,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -120,7 +118,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/generic.py b/src/taipy/core/data/generic.py
@@ -30,7 +30,6 @@ class GenericDataNode(DataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of the data node.
-        name (str): A user-readable name of the data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -67,7 +66,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -99,7 +97,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/in_memory.py b/src/taipy/core/data/in_memory.py
@@ -34,7 +34,6 @@ class InMemoryDataNode(DataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -66,7 +65,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -85,7 +83,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/json.py b/src/taipy/core/data/json.py
@@ -36,7 +36,6 @@ class JSONDataNode(DataNode, _AbstractFileDataNode):
             Python identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
         last_edit_date (datetime): The date and time of the last modification.
@@ -77,7 +76,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -101,7 +99,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/mongo.py b/src/taipy/core/data/mongo.py
@@ -30,7 +30,6 @@ class MongoCollectionDataNode(DataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             None.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -88,7 +87,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -114,7 +112,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/parquet.py b/src/taipy/core/data/parquet.py
@@ -39,7 +39,6 @@ class ParquetDataNode(DataNode, _AbstractFileDataNode, _AbstractTabularDataNode)
             Python identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
         last_edit_date (datetime): The date and time of the last modification.
@@ -99,7 +98,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -151,7 +149,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/pickle.py b/src/taipy/core/data/pickle.py
@@ -34,7 +34,6 @@ class PickleDataNode(DataNode, _AbstractFileDataNode):
             identifer.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             `None`.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -71,7 +70,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -95,7 +93,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/sql.py b/src/taipy/core/data/sql.py
@@ -30,7 +30,6 @@ class SQLDataNode(_AbstractSQLDataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             None.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -79,7 +78,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -102,7 +100,6 @@ def __init__(
             config_id,
             scope,
             id,
-            name,
             owner_id,
             parent_ids,
             last_edit_date,

diff --git a/src/taipy/core/data/sql_table.py b/src/taipy/core/data/sql_table.py
@@ -33,7 +33,6 @@ class SQLTableDataNode(_AbstractSQLDataNode):
             identifier.
         scope (Scope^): The scope of this data node.
         id (str): The unique identifier of this data node.
-        name (str): A user-readable name of this data node.
         owner_id (str): The identifier of the owner (sequence_id, scenario_id, cycle_id) or
             None.
         parent_ids (Optional[Set[str]]): The identifiers of the parent tasks or `None`.
@@ -78,7 +77,6 @@ def __init__(
         config_id: str,
         scope: Scope,
         id: Optional[DataNodeId] = None,
-        name: Optional[str] = None,
         owner_id: Optional[str] = None,
         parent_ids: Optional[Set[str]] = None,
         last_edit_date: Optional[datetime] = None,
@@ -98,7 +96,6 @@ def __init__(
             config_id,
             scope,
             id=id,
-            name=name,
             owner_id=owner_id,
             parent_ids=parent_ids,
             last_edit_date=last_edit_date,

diff --git a/...le_migrated/data_nodes/DATANODE_cleaned_dataset_0e715489-98ee-4a06-9b38-21409ed04d03.json b/...le_migrated/data_nodes/DATANODE_cleaned_dataset_0e715489-98ee-4a06-9b38-21409ed04d03.json
@@ -3,7 +3,6 @@
 "config_id": "cleaned_dataset",
 "scope": "<Scope.GLOBAL: 3>",
 "storage_type": "parquet",
-"name": null,
 "owner_id": null,
 "parent_ids": [
 "TASK_predict_cf8b3c83-5ea7-40eb-b8af-d5240852ff5b",
@@ -29,6 +28,7 @@
 "compression": "snappy",
 "exposed_type": "pandas",
 "read_kwargs": {},
-"write_kwargs": {}
+"write_kwargs": {},
+"name": null
 }
 }
diff --git a/...ty/data_sample_migrated/data_nodes/DATANODE_day_09c01a64-a998-4ba6-ac24-43e02db535a3.json b/...ty/data_sample_migrated/data_nodes/DATANODE_day_09c01a64-a998-4ba6-ac24-43e02db535a3.json
@@ -3,7 +3,6 @@
 "config_id": "day",
 "scope": "<Scope.SCENARIO: 1>",
 "storage_type": "pickle",
-"name": null,
 "last_edit_date": "2023-10-08T21:12:32.977796",
 "edits": [
 {
@@ -18,7 +17,8 @@
 "validity_seconds": null,
 "edit_in_progress": false,
 "data_node_properties": {
-"is_generated": true
+"is_generated": true,
+"name": null
 },
 "parent_ids": [
 "TASK_evaluate_57cbea3b-332e-47ac-a468-472e4885eb82",