diff --git a/swh/indexer/indexer.py b/swh/indexer/indexer.py --- a/swh/indexer/indexer.py +++ b/swh/indexer/indexer.py @@ -540,8 +540,7 @@ return self.process_journal_objects({"origin": origins}) def process_journal_objects(self, objects: ObjectsDict) -> Dict: - """Worker function for ``JournalClient``. Expects ``objects`` to have a single - key, either ``origin`` or ``"origin_visit_status"``.""" + """Worker function for ``JournalClient``.""" origins = [ Origin(url=status["origin"]) for status in objects.get("origin_visit_status", []) @@ -620,11 +619,12 @@ return self._process_directories([(dir_id, None) for dir_id in directory_ids]) def process_journal_objects(self, objects: ObjectsDict) -> Dict: - """Worker function for ``JournalClient``. Expects ``objects`` to have a single - key, ``"directory"``.""" - assert set(objects) == {"directory"} + """Worker function for ``JournalClient``.""" return self._process_directories( - [(dir_["id"], Directory.from_dict(dir_)) for dir_ in objects["directory"]] + [ + (dir_["id"], Directory.from_dict(dir_)) + for dir_ in objects.get("directory", []) + ] ) def _process_directories(