direct output: remove cache

app/nodes.py

@@ -58,13 +58,14 @@ def detect_file_type_node(state: GraphState) -> GraphState:
             # Check if we've already shown direct output for this exact file
             file_hash = compute_file_hash(state["file_content"])
             
-            if file_hash in _direct_output_cache:
-                logger.info(f"Direct output file already processed (hash: {file_hash[:8]}...) - will route to standard RAG for follow-up")
-                workflow_type = "standard"  # Override to standard for follow-up queries
-                is_cached_direct_output = True
-            else:
-                logger.info(f"Direct output mode enabled - new file will show ingestor results directly")
-                workflow_type = "direct_output"
+            # Comment out the cache check:
+            # if file_hash in _direct_output_cache:
+            #     logger.info(f"Direct output file already processed (hash: {file_hash[:8]}...) - will route to standard RAG for follow-up")
+            #     workflow_type = "standard"  # Override to standard for follow-up queries
+            #     is_cached_direct_output = True
+            # else:
+            logger.info(f"Direct output mode enabled - new file will show ingestor results directly")
+            workflow_type = "direct_output"
         else:
             # Direct output disabled - use standard workflow
             logger.info(f"Direct output mode disabled - using standard RAG pipeline")
@@ -100,20 +101,20 @@ def ingest_node(state: GraphState) -> GraphState:
     file_hash = state.get("file_hash")
     
     # Check cache ONLY if direct output is enabled and file was previously processed
-    if DIRECT_OUTPUT_ENABLED and file_hash and file_hash in _direct_output_cache:
-        cached_data = _direct_output_cache[file_hash]
-        logger.info(f"Using cached result for direct output file: {state['filename']}")
-        
-        metadata = state.get("metadata", {})
-        metadata.update({
-            "ingestion_duration": 0,
-            "ingestor_context_length": len(cached_data["ingestor_context"]),
-            "ingestion_success": True,
-            "cached": True,
-            "cache_timestamp": cached_data["timestamp"]
-        })
-        
-        return {"ingestor_context": cached_data["ingestor_context"], "metadata": metadata}
+    # if DIRECT_OUTPUT_ENABLED and file_hash and file_hash in _direct_output_cache:
+    #     cached_data = _direct_output_cache[file_hash]
+    #     logger.info(f"Using cached result for direct output file: {state['filename']}")
+        
+    #     metadata = state.get("metadata", {})
+    #     metadata.update({
+    #         "ingestion_duration": 0,
+    #         "ingestor_context_length": len(cached_data["ingestor_context"]),
+    #         "ingestion_success": True,
+    #         "cached": True,
+    #         "cache_timestamp": cached_data["timestamp"]
+    #     })
+        
+    #     return {"ingestor_context": cached_data["ingestor_context"], "metadata": metadata}
     
     # Standard processing (both for new direct output files and all standard files)
     logger.info(f"Ingesting {file_type} file: {state['filename']}")
@@ -139,14 +140,14 @@ def ingest_node(state: GraphState) -> GraphState:
             os.unlink(tmp_file_path)
         
         # Cache ONLY if direct output mode is enabled
-        if DIRECT_OUTPUT_ENABLED and file_hash:
-            _direct_output_cache[file_hash] = {
-                "ingestor_context": ingestor_context,
-                "timestamp": datetime.now().isoformat(),
-                "filename": state["filename"],
-                "file_type": file_type
-            }
-            logger.info(f"Cached direct output result for file hash: {file_hash[:8]}...")
+        # if DIRECT_OUTPUT_ENABLED and file_hash:
+        #     _direct_output_cache[file_hash] = {
+        #         "ingestor_context": ingestor_context,
+        #         "timestamp": datetime.now().isoformat(),
+        #         "filename": state["filename"],
+        #         "file_type": file_type
+        #     }
+        #     logger.info(f"Cached direct output result for file hash: {file_hash[:8]}...")
         
         duration = (datetime.now() - start_time).total_seconds()
         metadata = state.get("metadata", {})