diff --git a/surfsense_backend/app/tasks/connector_indexers/local_folder_indexer.py b/surfsense_backend/app/tasks/connector_indexers/local_folder_indexer.py
index f88d313da..a531916e1 100644
--- a/surfsense_backend/app/tasks/connector_indexers/local_folder_indexer.py
+++ b/surfsense_backend/app/tasks/connector_indexers/local_folder_indexer.py
@@ -153,7 +153,7 @@ def scan_folder(
     return files
 
 
-async def _read_file_content(file_path: str, filename: str, *, vision_llm=None) -> str:
+async def _read_file_content(file_path: str, filename: str) -> str:
     """Read file content via the unified ETL pipeline.
 
     All file types (plaintext, audio, direct-convert, document, image) are
@@ -162,7 +162,7 @@ async def _read_file_content(file_path: str, filename: str, *, vision_llm=None)
     from app.etl_pipeline.etl_document import EtlRequest
     from app.etl_pipeline.etl_pipeline_service import EtlPipelineService
 
-    result = await EtlPipelineService(vision_llm=vision_llm).extract(
+    result = await EtlPipelineService().extract(
         EtlRequest(file_path=file_path, filename=filename)
     )
     return result.markdown_content
@@ -199,14 +199,12 @@ async def _compute_file_content_hash(
     file_path: str,
     filename: str,
     search_space_id: int,
-    *,
-    vision_llm=None,
 ) -> tuple[str, str]:
     """Read a file (via ETL if needed) and compute its content hash.
 
     Returns (content_text, content_hash).
     """
-    content = await _read_file_content(file_path, filename, vision_llm=vision_llm)
+    content = await _read_file_content(file_path, filename)
     return content, _content_hash(content, search_space_id)
 
 
@@ -637,10 +635,6 @@ async def index_local_folder(
 
         page_limit_service = PageLimitService(session)
 
-        from app.services.llm_service import get_vision_llm
-
-        vision_llm = await get_vision_llm(session, search_space_id)
-
         # ================================================================
         # PHASE 1: Pre-filter files (mtime / content-hash), version changed
         # ================================================================
@@ -713,7 +707,6 @@ async def index_local_folder(
                             file_path_abs,
                             file_info["relative_path"],
                             search_space_id,
-                            vision_llm=vision_llm,
                         )
                     except Exception as read_err:
                         logger.warning(f"Could not read {file_path_abs}: {read_err}")
@@ -750,7 +743,6 @@ async def index_local_folder(
                             file_path_abs,
                             file_info["relative_path"],
                             search_space_id,
-                            vision_llm=vision_llm,
                         )
                     except Exception as read_err:
                         logger.warning(f"Could not read {file_path_abs}: {read_err}")
@@ -1092,13 +1084,9 @@ async def _index_single_file(
         except PageLimitExceededError as e:
             return 0, 1, f"Page limit exceeded: {e}"
 
-        from app.services.llm_service import get_vision_llm
-
-        vision_llm = await get_vision_llm(session, search_space_id)
-
         try:
             content, content_hash = await _compute_file_content_hash(
-                str(full_path), full_path.name, search_space_id, vision_llm=vision_llm
+                str(full_path), full_path.name, search_space_id
             )
         except Exception as e:
             return 0, 1, f"Could not read file: {e}"
@@ -1316,10 +1304,6 @@ async def index_uploaded_files(
         pipeline = IndexingPipelineService(session)
         llm = await get_user_long_context_llm(session, user_id, search_space_id)
 
-        from app.services.llm_service import get_vision_llm
-
-        vision_llm = await get_vision_llm(session, search_space_id)
-
         indexed_count = 0
         failed_count = 0
         errors: list[str] = []
@@ -1367,7 +1351,7 @@ async def index_uploaded_files(
 
                 try:
                     content, content_hash = await _compute_file_content_hash(
-                        temp_path, filename, search_space_id, vision_llm=vision_llm
+                        temp_path, filename, search_space_id
                     )
                 except Exception as e:
                     logger.warning(f"Could not read {relative_path}: {e}")