diff --git a/swh/core/db/__init__.py b/swh/core/db/__init__.py
--- a/swh/core/db/__init__.py
+++ b/swh/core/db/__init__.py
@@ -295,3 +295,7 @@
 
     def mktemp(self, tblname: str, cur: Optional[psycopg2.extensions.cursor] = None):
         self.cursor(cur).execute("SELECT swh_mktemp(%s)", (tblname,))
+
+    def get_current_version(self) -> int:
+        assert hasattr(self, "current_version")
+        return self.current_version