diff --git a/lib/galaxy/managers/jobs.py b/lib/galaxy/managers/jobs.py
index d08554a55651..14605c45759f 100644
--- a/lib/galaxy/managers/jobs.py
+++ b/lib/galaxy/managers/jobs.py
@@ -576,7 +576,7 @@ def replace_dataset_ids(path, key, value):
                 else:
                     return []
 
-            query = query.where(*data_conditions).group_by(model.Job.id, *used_ids).order_by(model.Job.id.desc())
+        query = query.where(*data_conditions).group_by(model.Job.id, *used_ids).order_by(model.Job.id.desc())
 
         for job in self.sa_session.execute(query):
             # We found a job that is equal in terms of tool_id, user, state and input datasets,