fix: properly remove activities in workflow remove if catalog is corrupt

SwissDataScienceCenter · Jul 11, 2024 · ab53900 · ab53900
1 parent ed58a8d
commit ab53900
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/renku/infrastructure/gateway/activity_gateway.py b/renku/infrastructure/gateway/activity_gateway.py
@@ -272,6 +272,10 @@ def _index_activity(activity: Activity, database: Database):
 
 def _unindex_activity(activity: Activity, database: Database):
     """Add an activity to database indexes and create its up/downstream relations."""
+    # there are cases where the activity catalog can be corrupt and removing activities doesn't actually remove them
+    # here we reindex them so removal works as expected
+    reindex_catalog(database)
+
     upstreams = set()
     downstreams = set()