diff --git a/orchestrator/activities/mongo_db.py b/orchestrator/activities/mongo_db.py
index 0339ab5..4ae3a96 100644
--- a/orchestrator/activities/mongo_db.py
+++ b/orchestrator/activities/mongo_db.py
@@ -393,7 +393,9 @@ class MongoDB(SientiaMonitoring):
         created_indexes = []
 
         for _pipeline_name, pipeline_config in pipelines.items():
-            collection = pipeline_config['topic']
+            collection = pipeline_config.get('topic', None)
+            if not collection:
+                continue
 
             try:
                 # Check if collection exists