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