diff --git a/swh/storage/cassandra/cql.py b/swh/storage/cassandra/cql.py --- a/swh/storage/cassandra/cql.py +++ b/swh/storage/cassandra/cql.py @@ -459,18 +459,6 @@ # 'content_by_*' tables ########################## - @_prepared_statement( - f""" - SELECT sha1_git AS id - FROM {content_index_table_name("sha1_git", skipped_content=False)} - WHERE sha1_git IN ? - """ - ) - def content_missing_by_sha1_git( - self, ids: List[bytes], *, statement - ) -> List[bytes]: - return self._missing(statement, ids) - def content_index_add_one(self, algo: str, content: Content, token: int) -> None: """Adds a row mapping content[algo] to the token of the Content in the main 'content' table.""" diff --git a/swh/storage/cassandra/storage.py b/swh/storage/cassandra/storage.py --- a/swh/storage/cassandra/storage.py +++ b/swh/storage/cassandra/storage.py @@ -962,7 +962,7 @@ queries: List[Tuple[str, Callable[[List[Sha1Git]], List[Sha1Git]]]] = [ ("revision", self._cql_runner.revision_missing), ("release", self._cql_runner.release_missing), - ("content", self._cql_runner.content_missing_by_sha1_git), + ("content", self.content_missing_per_sha1_git), ("directory", self._cql_runner.directory_missing), ]