diff --git a/repositories/uploaded_file/uploaded_file_postgres_repository.py b/repositories/uploaded_file/uploaded_file_postgres_repository.py index 107bc6592..82c711231 100644 --- a/repositories/uploaded_file/uploaded_file_postgres_repository.py +++ b/repositories/uploaded_file/uploaded_file_postgres_repository.py @@ -31,7 +31,10 @@ class UploadedFilePostgresRepository: `landlord_property_id` (ADR-0060), across all Document Types. Returns the raw rows — latest-per-Document-Type selection and null-type skipping are the Download Package plan's job, not the query's.""" - raise NotImplementedError + stmt = select(UploadedFile).where( + col(UploadedFile.landlord_property_id).in_(list(landlord_property_ids)) + ) + return list(self._session.execute(stmt).scalars().all()) # pyright: ignore[reportDeprecated] def insert(self, uploaded_file: UploadedFile) -> None: self._session.add(uploaded_file)