Refresh python packages

infrahub_sdk/ctl/repository.py

@@ -102,6 +102,8 @@ async def add(
             password=password,
         )
         await credential.save(allow_upsert=True)
+        if not credential.id:
+            raise ValueError("credential.id must be set before building the request")
         input_data["data"]["credential"] = {"id": credential.id}
 
     query = Mutation(

infrahub_sdk/node/node.py

@@ -5,7 +5,13 @@
 from typing import TYPE_CHECKING, Any
 
 from ..constants import InfrahubClientMode
-from ..exceptions import FeatureNotSupportedError, NodeNotFoundError, ResourceNotDefinedError, SchemaNotFoundError
+from ..exceptions import (
+    FeatureNotSupportedError,
+    NodeNotFoundError,
+    ResourceNotDefinedError,
+    SchemaNotFoundError,
+    UninitializedError,
+)
 from ..graphql import Mutation, Query
 from ..schema import GenericSchemaAPI, RelationshipCardinality, RelationshipKind
 from ..utils import compare_lists, generate_short_id, get_flat_value
@@ -574,8 +580,9 @@ async def artifact_generate(self, name: str) -> None:
         self._validate_artifact_support(ARTIFACT_GENERATE_FEATURE_NOT_SUPPORTED_MESSAGE)
 
         artifact = await self._client.get(kind="CoreArtifact", name__value=name, object__ids=[self.id])
-        await artifact._get_relationship_one(name="definition").fetch()
-        await artifact._get_relationship_one(name="definition").peer.generate([artifact.id])
+        if artifact.id:
+            await artifact._get_relationship_one(name="definition").fetch()
+            await artifact._get_relationship_one(name="definition").peer.generate([artifact.id])
 
     async def artifact_fetch(self, name: str) -> str | dict[str, Any]:
         self._validate_artifact_support(ARTIFACT_GENERATE_FEATURE_NOT_SUPPORTED_MESSAGE)
@@ -619,16 +626,21 @@ async def save(
 
         if not isinstance(self._schema, GenericSchemaAPI):
             if "CoreGroup" in self._schema.inherit_from:
+                if self.id is None:
+                    raise UninitializedError("Cannot add related groups before the node has an ID")
                 await self._client.group_context.add_related_groups(
                     ids=[self.id], update_group_context=update_group_context
                 )
             else:
+                if self.id is None:
+                    raise UninitializedError("Cannot add related nodes before the node has an ID")
                 await self._client.group_context.add_related_nodes(
                     ids=[self.id], update_group_context=update_group_context
                 )
         else:
+            if self.id is None:
+                raise UninitializedError("Cannot add related nodes before the node has an ID")
             await self._client.group_context.add_related_nodes(ids=[self.id], update_group_context=update_group_context)
-
         self._client.store.set(node=self)
 
     async def generate_query_data(
@@ -813,7 +825,7 @@ async def _process_mutation_result(
         self, mutation_name: str, response: dict[str, Any], timeout: int | None = None
     ) -> None:
         object_response: dict[str, Any] = response[mutation_name]["object"]
-        self.id = object_response["id"]
+        self.id = str(object_response["id"])
         self._existing = True
 
         for attr_name in self._attributes:
@@ -1161,8 +1173,9 @@ def generate(self, nodes: list[str] | None = None) -> None:
     def artifact_generate(self, name: str) -> None:
         self._validate_artifact_support(ARTIFACT_GENERATE_FEATURE_NOT_SUPPORTED_MESSAGE)
         artifact = self._client.get(kind="CoreArtifact", name__value=name, object__ids=[self.id])
-        artifact._get_relationship_one(name="definition").fetch()
-        artifact._get_relationship_one(name="definition").peer.generate([artifact.id])
+        if artifact.id:
+            artifact._get_relationship_one(name="definition").fetch()
+            artifact._get_relationship_one(name="definition").peer.generate([artifact.id])
 
     def artifact_fetch(self, name: str) -> str | dict[str, Any]:
         self._validate_artifact_support(ARTIFACT_FETCH_FEATURE_NOT_SUPPORTED_MESSAGE)
@@ -1205,10 +1218,17 @@ def save(
 
         if not isinstance(self._schema, GenericSchemaAPI):
             if "CoreGroup" in self._schema.inherit_from:
+                if self.id is None:
+                    raise UninitializedError("Cannot add related nodes before the node has an ID")
                 self._client.group_context.add_related_groups(ids=[self.id], update_group_context=update_group_context)
+
             else:
+                if self.id is None:
+                    raise UninitializedError("Cannot add related nodes before the node has an ID")
                 self._client.group_context.add_related_nodes(ids=[self.id], update_group_context=update_group_context)
         else:
+            if self.id is None:
+                raise UninitializedError("Cannot add related nodes before the node has an ID")
             self._client.group_context.add_related_nodes(ids=[self.id], update_group_context=update_group_context)
 
         self._client.store.set(node=self)
@@ -1394,7 +1414,7 @@ def _process_mutation_result(
         self, mutation_name: str, response: dict[str, Any], timeout: int | None = None
     ) -> None:
         object_response: dict[str, Any] = response[mutation_name]["object"]
-        self.id = object_response["id"]
+        self.id = str(object_response["id"])
         self._existing = True
 
         for attr_name in self._attributes:

infrahub_sdk/node/related_node.py

@@ -34,7 +34,7 @@ def __init__(self, branch: str, schema: RelationshipSchemaAPI, data: Any | dict,
         self._properties_object = PROPERTIES_OBJECT
         self._properties = self._properties_flag + self._properties_object
 
-        self._peer = None
+        self._peer: CoreNodeBase | InfrahubNode | InfrahubNodeSync | None = None
         self._id: str | None = None
         self._hfid: list[str] | None = None
         self._display_label: str | None = None
@@ -64,7 +64,7 @@ def __init__(self, branch: str, schema: RelationshipSchemaAPI, data: Any | dict,
                 self._display_label = node_data.get("display_label", None)
                 self._typename = node_data.get("__typename", None)
 
-            self.updated_at: str | None = data.get("updated_at", data.get("_relation__updated_at", None))
+            self.updated_at: str | None = data.get("updated_at", data.get("_relation__updated_at"))
 
             # FIXME, we won't need that once we are only supporting paginated results
             if self._typename and self._typename.startswith("Related"):

infrahub_sdk/pytest_plugin/items/jinja2_transform.py

@@ -83,7 +83,7 @@ def repr_failure(self, excinfo: ExceptionInfo, style: str | None = None) -> str:
 class InfrahubJinja2TransformSmokeItem(InfrahubJinja2Item):
     def runtest(self) -> None:
         file_path: Path = self.session.infrahub_config_path.parent / self.resource_config.template_path  # type: ignore[attr-defined]
-        self.get_jinja2_environment().parse(file_path.read_text(), filename=file_path.name)
+        self.get_jinja2_environment().parse(file_path.read_text(encoding="utf-8"), filename=file_path.name)
 
 
 class InfrahubJinja2TransformUnitRenderItem(InfrahubJinja2Item):

infrahub_sdk/pytest_plugin/utils.py

@@ -11,7 +11,7 @@ def load_repository_config(repo_config_file: Path) -> InfrahubRepositoryConfig:
         raise FileNotFoundError(repo_config_file)
 
     try:
-        yaml_data = repo_config_file.read_text()
+        yaml_data = repo_config_file.read_text(encoding="utf-8")
         data = yaml.safe_load(yaml_data)
     except yaml.YAMLError as exc:
         raise FileNotValidError(name=str(repo_config_file)) from exc

infrahub_sdk/transfer/importer/json.py

@@ -65,7 +65,8 @@ async def import_data(self, import_directory: Path, branch: str) -> None:
             for graphql_data, kind in zip(table.column("graphql_json"), table.column("kind")):
                 node = await InfrahubNode.from_graphql(self.client, branch, ujson.loads(str(graphql_data)))
                 import_nodes_by_kind[str(kind)].append(node)
-                self.all_nodes[node.id] = node
+                if node.id:
+                    self.all_nodes[node.id] = node
 
         schema_batch = await self.client.create_batch()
         for kind in import_nodes_by_kind:
@@ -112,11 +113,11 @@ async def remove_and_store_optional_relationships(self) -> None:
             for relationship_name in self.optional_relationships_schemas_by_node_kind[node_kind].keys():
                 relationship_value = getattr(node, relationship_name)
                 if isinstance(relationship_value, RelationshipManager):
-                    if relationship_value.peer_ids:
+                    if relationship_value.peer_ids and node.id:
                         self.optional_relationships_by_node[node.id][relationship_name] = relationship_value
                         setattr(node, relationship_name, None)
                 elif isinstance(relationship_value, RelatedNode):
-                    if relationship_value.id:
+                    if relationship_value.id and node.id:
                         self.optional_relationships_by_node[node.id][relationship_name] = relationship_value
                         setattr(node, relationship_name, None)
 
@@ -144,7 +145,7 @@ async def update_optional_relationships(self) -> None:
         await self.execute_batches([update_batch], "Adding optional relationships to nodes")
 
     async def update_many_to_many_relationships(self, file: Path) -> None:
-        relationships = ujson.loads(file.read_text())
+        relationships = ujson.loads(file.read_text(encoding="utf-8"))
         update_batch = await self.client.create_batch(return_exceptions=True)
 
         for relationship in relationships:

infrahub_sdk/utils.py

@@ -331,7 +331,7 @@ def write_to_file(path: Path, value: Any) -> bool:
         raise FileExistsError(f"{path} is a directory")
 
     to_write = str(value)
-    written = path.write_text(to_write)
+    written = path.write_text(data=to_write, encoding="utf-8")
 
     return written is not None