diff --git a/mrq/basetasks/utils.py b/mrq/basetasks/utils.py index 2fa18c5b..8763d21c 100644 --- a/mrq/basetasks/utils.py +++ b/mrq/basetasks/utils.py @@ -154,6 +154,6 @@ def perform_action(self, action, query, destination_queue): "_id": {"$in": jobs_by_queue[queue]} }, {"$set": updates}, multi=True) - set_queues_size({queue: len(jobs) for queue, jobs in jobs_by_queue.iteritems()}) + set_queues_size({queue: len(jobs) for queue, jobs in jobs_by_queue.items()}) return stats