Prevent crash when account is created with non-existent namespace.

spark8t/cli/service_account_registry.py

@@ -17,6 +17,7 @@
     AccountNotFound,
     PrimaryAccountNotFound,
     ResourceAlreadyExists,
+    K8sResourceNotFound
 )
 from spark8t.services import K8sServiceAccountRegistry, parse_conf_overrides
 from spark8t.utils import setup_logging
@@ -199,7 +200,7 @@ def main(args: Namespace, logger: Logger):
     try:
         main(args, logger)
         exit(0)
-    except (AccountNotFound, PrimaryAccountNotFound, ResourceAlreadyExists) as e:
+    except (AccountNotFound, PrimaryAccountNotFound, ResourceAlreadyExists, K8sResourceNotFound) as e:
         print(str(e))
         exit(1)
     except Exception as e:

spark8t/exceptions.py

@@ -1,3 +1,6 @@
+from spark8t.domain import KubernetesResourceType
+
+
 class K8sClusterNotReachable(Exception):
     """Kubernetes cluster cannot be reached successfully by the client."""
 
@@ -52,3 +55,11 @@ class FormatError(SyntaxError):
 
 class ResourceAlreadyExists(FileExistsError):
     pass
+
+
+class NamespaceNotFound(K8sResourceNotFound):
+    def __init__(self, resource_name: str):
+        super().__init__(resource_name, resource_type=KubernetesResourceType.NAMESPACE)
+
+    def __str__(self) -> str:
+        return f"Namespace '{self.resource_name}' could not be found."

spark8t/services.py

@@ -31,6 +31,7 @@
     AccountNotFound,
     FormatError,
     K8sResourceNotFound,
+    NamespaceNotFound,
     ResourceAlreadyExists,
 )
 from spark8t.literals import MANAGED_BY_LABELNAME, PRIMARY_LABELNAME, SPARK8S_LABEL
@@ -1180,6 +1181,12 @@ def create(self, service_account: ServiceAccount) -> str:
         rolename = username + "-role"
         rolebindingname = username + "-role-binding"
 
+        if not self.kube_interface.exists(
+            KubernetesResourceType.NAMESPACE,
+            service_account.namespace,
+        ):
+            raise NamespaceNotFound(service_account.namespace)
+
         # Check if the resources to be created already exist in K8s cluster
         if self.kube_interface.exists(
             KubernetesResourceType.SERVICEACCOUNT,