diff --git a/cv_analysis/server/stream.py b/cv_analysis/server/stream.py
index df93576..a73ae05 100644
--- a/cv_analysis/server/stream.py
+++ b/cv_analysis/server/stream.py
@@ -7,7 +7,7 @@ from pyinfra.server.utils import make_streamable_and_wrap_in_packing_logic
 
 from cv_analysis.server.format import make_formatter
 from cv_analysis.utils.logging import get_logger
-from cv_analysis.utils.open_img import open_img
+from cv_analysis.utils.open_pdf import open_pdf
 
 logger = get_logger()
 
@@ -26,7 +26,7 @@ def make_streamable_analysis_fn(analysis_fn: Callable):
 
     def analyse(data: bytes, metadata: dict):
 
-        image = open_img(gzip.decompress(data))[0]
+        image = open_pdf(gzip.decompress(data))[0]
 
         dpi = metadata["image_info"]["dpi"]
         width, height, rotation = itemgetter("width", "height", "rotation")(metadata["page_info"])