diff --git a/lib/rucio/core/rule.py b/lib/rucio/core/rule.py index c293b71340..42a58e9be1 100644 --- a/lib/rucio/core/rule.py +++ b/lib/rucio/core/rule.py @@ -2027,7 +2027,7 @@ def get_updated_dids(total_workers: int, worker_number: int, limit: int = 100, b else: return filtered_dids else: - return [did for did in session.execute(stmt.order_by(models.UpdatedDID.created_at)).all() if (did.scope, did.name) not in blocked_dids] + return [did for did in session.execute(stmt.order_by(models.UpdatedDID.created_at)).all() if (did.scope, did.name) not in blocked_dids] # type: ignore @read_session @@ -2055,7 +2055,7 @@ def get_rules_beyond_eol(date_check: datetime, worker_number: int, total_workers stmt = filter_thread_work(session=session, query=stmt, total_threads=total_workers, thread_id=worker_number, hash_variable='name') result = session.execute(stmt).all() - return [rule for rule in result] + return [rule for rule in result] # type: ignore @read_session @@ -2095,9 +2095,9 @@ def get_expired_rules(total_workers: int, worker_number: int, limit: int = 100, blocked_rules=blocked_rules, session=session) else: - return filtered_rules + return filtered_rules # type: ignore else: - return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] + return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] # type: ignore @read_session @@ -2135,9 +2135,9 @@ def get_injected_rules(total_workers: int, worker_number: int, limit: int = 100, blocked_rules=blocked_rules, session=session) else: - return filtered_rules + return filtered_rules # type: ignore else: - return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] + return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] # type: ignore @read_session @@ -2179,9 +2179,9 @@ def get_stuck_rules(total_workers: int, worker_number: int, delta: int = 600, li blocked_rules=blocked_rules, session=session) else: - return filtered_rules + return filtered_rules # type: ignore else: - return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] + return [rule for rule in session.execute(stmt).all() if rule._mapping['id'] not in blocked_rules] # type: ignore @transactional_session