diff --git a/config-data-executor/src/main/java/org/micord/service/RequestService.java b/config-data-executor/src/main/java/org/micord/service/RequestService.java
index 3015ced..449534b 100644
--- a/config-data-executor/src/main/java/org/micord/service/RequestService.java
+++ b/config-data-executor/src/main/java/org/micord/service/RequestService.java
@@ -565,7 +565,7 @@ public class RequestService {
     List<String> collectionNames = new ArrayList<>();
 
     request.getAqlRequestCollections().forEach(collection -> {
-        collectionNames.add(collection.getCollectionUrl());  // Use collection URL instead of type
+        collectionNames.add(collection.getType());
     });
     StreamTransactionEntity tx = null;
     try {