delay=1,
fallback=Exception("Failed creating the namespace"),
)
- async def create_namespace(self, name: str):
+ async def create_namespace(self, name: str, labels: dict = None):
"""
Create a namespace
:param: name: Name of the namespace to be created
+ :param: labels: Dictionary with labels for the new namespace
"""
v1_core = self.clients[CORE_CLIENT]
- metadata = V1ObjectMeta(name=name)
+ metadata = V1ObjectMeta(name=name, labels=labels)
namespace = V1Namespace(
metadata=metadata,
)