diff --git a/orchestrator/utils/orchestrator_functions.py b/orchestrator/utils/orchestrator_functions.py
index 6d18011..5375e14 100644
--- a/orchestrator/utils/orchestrator_functions.py
+++ b/orchestrator/utils/orchestrator_functions.py
@@ -128,7 +128,7 @@ def gather_read_tags(pipelines: list[dict[str, Any]]) -> dict[str, Any]:
 
     # Get all read tags from pipelines
     for pipeline in pipelines:
-        for tag in pipeline['read_tags']:
+        for tag in pipeline.get('read_tags', []):
             tag_string = f"{tag['server_id']}:{tag['tag_address']}"
             if tag_string not in tags:
                 tags[tag_string] = {
diff --git a/samples.json b/samples.json
index 336ef01..18c7177 100644
--- a/samples.json
+++ b/samples.json
@@ -66,7 +66,7 @@
             "max_retry_policy": 1,
             "query": "select * from sientia_data.laborious_data order by \"timestamp\" desc limit 30;",
             "retention_time": 60,
-            "opc_output_config": [
+            "write_tags": [
               {
                 "server_id": "1",
                 "type": "prediction",