[resotoworker] [fix] Use /ancestors during cleanup (#617)

someengineering · Feb 3, 2022 · 1d62780 · 1d62780
1 parent 708202f
commit 1d62780
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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:]->"
     )