deleted namespace after test

src/robusta/core/sinks/robusta/dal/supabase_dal.py

@@ -414,7 +414,24 @@ def remove_deleted_job(self, job: JobInfo):
                 .execute()
             )
         except Exception as e:
-            logging.error(f"Failed to delete job {job} error: {e}")
+            logging.exception(f"Failed to delete job {job} error: {e}")
+            raise
+
+    def remove_deleted_namespace(self, namespace_name: str):
+        if not namespace_name:
+            return
+
+        try:
+            (
+                self.client.table(NAMESPACES_TABLE)
+                .delete(returning=ReturnMethod.minimal)
+                .filter("account_id", "eq", self.account_id)
+                .filter("cluster_id", "eq", self.cluster)
+                .eq("name", namespace_name)
+                .execute()
+            )
+        except Exception as e:
+            logging.exception(f"Failed to delete namespace {namespace_name} error: {e}")
             raise
 
     # helm release

src/robusta/core/sinks/robusta/robusta_sink.py

@@ -596,14 +596,12 @@ def __publish_new_namespaces(self, namespaces: List[NamespaceInfo]):
 
         # handle deleted namespaces
         updated_namespaces: List[NamespaceInfo] = []
-        for namespace_name, namespace in self.__namespaces_cache.items():
+        cache_keys = list(self.__namespaces_cache.keys())
+        for namespace_name in cache_keys:
             if namespace_name not in curr_namespaces:
-                namespace.deleted = True
-                updated_namespaces.append(namespace)
-
-        for update in updated_namespaces:
-            if update.deleted:
-                del self.__namespaces_cache[update.name]
+                # namespace was deleted from cluster
+                self.__namespaces_cache.pop(namespace_name, None)
+                self.dal.remove_deleted_namespace(namespace_name)
 
         # new or changed namespaces
         for namespace_name, updated_namespace in curr_namespaces.items():