From 53289fe789b6fbb7ae0f7981fa105ce30f83a244 Mon Sep 17 00:00:00 2001 From: phact Date: Mon, 29 Sep 2025 14:00:58 -0400 Subject: [PATCH] remove file_info_map which was unused --- src/models/processors.py | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/src/models/processors.py b/src/models/processors.py index 87562424..8d399e86 100644 --- a/src/models/processors.py +++ b/src/models/processors.py @@ -245,15 +245,6 @@ class ConnectorFileProcessor(TaskProcessor): self.jwt_token = jwt_token self.owner_name = owner_name self.owner_email = owner_email - # Create lookup map for file info - handle both file objects and file IDs - self.file_info_map = {} - for f in files_to_process: - if isinstance(f, dict): - # Full file info objects - self.file_info_map[f["id"]] = f - else: - # Just file IDs - will need to fetch metadata during processing - self.file_info_map[f] = None async def process_item( self, upload_task: UploadTask, item: str, file_task: FileTask @@ -352,15 +343,6 @@ class LangflowConnectorFileProcessor(TaskProcessor): self.jwt_token = jwt_token self.owner_name = owner_name self.owner_email = owner_email - # Create lookup map for file info - handle both file objects and file IDs - self.file_info_map = {} - for f in files_to_process: - if isinstance(f, dict): - # Full file info objects - self.file_info_map[f["id"]] = f - else: - # Just file IDs - will need to fetch metadata during processing - self.file_info_map[f] = None async def process_item( self, upload_task: UploadTask, item: str, file_task: FileTask