diff --git a/src/data_disclosure/tasks.py b/src/data_disclosure/tasks.py
index cbedfe2263c0e50ce16b449398e497cad70f96ae..6acacbef58eca5b3024af76ac6381ded9f969adc 100644
--- a/src/data_disclosure/tasks.py
+++ b/src/data_disclosure/tasks.py
@@ -42,7 +42,7 @@ class DataDisclosureProcessor:
         Get all XAPI statements matching a user email address from database.
         """
         collection = lrs_db["statements"]
-        query = {"actor.mbox": f"mailto:{user_email}"}
+        query = {"actor.account": f"name:{user_email}"}
         cursor = collection.find(query)
         return [
             (