diff --git a/resotoworker/resotoworker/cleanup.py b/resotoworker/resotoworker/cleanup.py
index d25f0a71de..ef8c7128b7 100644
--- a/resotoworker/resotoworker/cleanup.py
+++ b/resotoworker/resotoworker/cleanup.py
@@ -14,7 +14,7 @@ def cleanup():
     query_filter = ""
     if ArgumentParser.args.collector and len(ArgumentParser.args.collector) > 0:
         clouds = '["' + '", "'.join(ArgumentParser.args.collector) + '"]'
-        query_filter = f"and metadata.ancestors.cloud.id in {clouds} "
+        query_filter = f"and /ancestors.cloud.reported.id in {clouds} "
     query = (
         f"desired.clean == true and metadata.cleaned == false {query_filter}<-[0:]->"
     )