diff --git a/infrastructure/s3/s3_document_bytes_reader.py b/infrastructure/s3/s3_document_bytes_reader.py index 930377740..2e0739249 100644 --- a/infrastructure/s3/s3_document_bytes_reader.py +++ b/infrastructure/s3/s3_document_bytes_reader.py @@ -16,4 +16,6 @@ class S3DocumentBytesReader: self._client = boto_s3_client def read(self, bucket: str, key: str) -> bytes: - raise NotImplementedError + response: dict[str, Any] = self._client.get_object(Bucket=bucket, Key=key) + body: bytes = response["Body"].read() + return body