diff --git a/requirements-swh.txt b/requirements-swh.txt --- a/requirements-swh.txt +++ b/requirements-swh.txt @@ -1 +1 @@ -swh.core >= 0.0.48 +swh.core >= 0.0.51 diff --git a/swh/scheduler/updater/backend.py b/swh/scheduler/updater/backend.py --- a/swh/scheduler/updater/backend.py +++ b/swh/scheduler/updater/backend.py @@ -72,9 +72,7 @@ q = format_query('select {keys} from swh_cache_read(%s, %s)', self.cache_read_keys) cur.execute(q, (timestamp, limit)) - for r in cur.fetchall(): - r['id'] = r['id'].tobytes() - yield r + yield from cur.fetchall() @db_transaction() def cache_remove(self, entries, db=None, cur=None):