diff --git a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java
index d6809c0..6305588 100644
--- a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java
+++ b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java
@@ -39,7 +39,7 @@ public void save(Decision decision) {
     @Override
     public Decision get(DecisionId decisionId) {
         Query q = Query.query(
-                        Criteria.where("decisionId")
+                        Criteria.where("aggregateId")
                                 .is(decisionId.toString())
                 )
                 .with(Sort.by("version"));