Core & Internals: Regression fix for judge #6569

rucio · Mar 15, 2024 · 7537063 · 7537063
1 parent 1fc0c97
commit 7537063
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/rucio/core/rule.py b/lib/rucio/core/rule.py
@@ -2113,8 +2113,8 @@ def get_updated_dids(
         stmt = stmt.where(tuple_(models.UpdatedDID.scope, models.UpdatedDID.name).notin_(chunk))
 
     if limit:
-        fetched_dids = stmt.order_by(models.UpdatedDID.created_at).limit(limit).all()
-        filtered_dids = [did for did in fetched_dids if (did.scope, did.name) not in blocked_dids]
+        fetched_dids = session.execute(stmt.order_by(models.UpdatedDID.created_at).limit(limit)).all()
+        filtered_dids = [did._tuple() for did in fetched_dids if (did.scope, did.name) not in blocked_dids]
         if len(fetched_dids) == limit and not filtered_dids:
             return get_updated_dids(total_workers=total_workers,
                                     worker_number=worker_number,