- namespaces = await self._get_namespaces(cluster_id)
- if namespace not in namespaces:
- await self._create_namespace(cluster_id, namespace)
+ if not await self._namespace_exists(cluster_id, namespace):
+ try:
+ await self._create_namespace(cluster_id, namespace)
+ except Exception as e:
+ if not await self._namespace_exists(cluster_id, namespace):
+ err_msg = (
+ "namespace {} does not exist in cluster_id {} "
+ "error message: ".format(
+ namespace, e
+ )
+ )
+ self.log.error(err_msg)
+ raise K8sException(err_msg)