fix some lint

Zongwei9888 · Zongwei9888 · commit db60ecc58f4a · 2025-07-21T13:11:19.000+08:00
diff --git a/ui/components.py b/ui/components.py
@@ -719,7 +719,7 @@ def file_input_component(task_counter: int) -> Optional[str]:
                         # Clean up original file
                         try:
                             os.unlink(original_file_path)
-                        except:
+                        except Exception:
                             pass
                         return None
 
@@ -729,7 +729,7 @@ def file_input_component(task_counter: int) -> Optional[str]:
                     # Clean up original file
                     try:
                         os.unlink(original_file_path)
-                    except:
+                    except Exception:
                         pass
 
                     # Display conversion result
@@ -751,7 +751,7 @@ def file_input_component(task_counter: int) -> Optional[str]:
                     # Clean up original file
                     try:
                         os.unlink(original_file_path)
-                    except:
+                    except Exception:
                         pass
                     return None
 
@@ -982,7 +982,7 @@ def results_display_component(result: Dict[str, Any], task_counter: int):
                         height=300,
                         key=f"analysis_{task_counter}",
                     )
-            except:
+            except Exception:
                 st.text_area(
                     "Analysis Output",
                     analysis_result,
@@ -1296,9 +1296,6 @@ def enhanced_progress_display_component(
                 ),  # Jump directly to implementation
             ]
 
-        # Create step indicator container
-        step_container = st.container()
-
         # Display step grid with fixed layout
         # Use a maximum of 8 columns for consistent sizing
         max_cols = 8
@@ -1350,9 +1347,6 @@ def enhanced_progress_display_component(
         # Status text display
         status_text = st.empty()
 
-        # Real-time information display
-        info_text = st.empty()
-
         # Display mode information
         if not enable_indexing:
             st.info(
diff --git a/ui/handlers.py b/ui/handlers.py
@@ -169,7 +169,6 @@ def run_async_task(coro):
         from streamlit.runtime.scriptrunner.script_run_context import (
             SCRIPT_RUN_CONTEXT_ATTR_NAME,
         )
-        import threading
 
         current_ctx = get_script_run_ctx()
         context_available = True
@@ -584,7 +583,7 @@ def cleanup_temp_file(input_source: str, input_type: str):
     if input_type == "file" and input_source and os.path.exists(input_source):
         try:
             os.unlink(input_source)
-        except:
+        except Exception:
             pass
 
 
diff --git a/utils/cli_interface.py b/utils/cli_interface.py
@@ -168,7 +168,7 @@ def select_file():
                     # macOS specific settings
                     try:
                         root.call("wm", "attributes", ".", "-topmost", True)
-                    except:
+                    except Exception:
                         pass
 
                     # macOS compatible file types
@@ -211,7 +211,7 @@ def select_file():
                     # Clean up
                     try:
                         root.destroy()
-                    except:
+                    except Exception:
                         pass
 
                 return file_path
@@ -221,7 +221,7 @@ def select_file():
                 try:
                     if "root" in locals():
                         root.destroy()
-                except:
+                except Exception:
                     pass
 
                 # Print error and suggest alternative
diff --git a/workflows/agents/code_implementation_agent.py b/workflows/agents/code_implementation_agent.py
@@ -414,7 +414,9 @@ async def _track_file_implementation_with_summary(
                         self.get_files_implemented_count(),  # Pass the current file count
                     )
 
-                    # self.logger.info(f"Created code summary for implemented file: {file_path}")
+                    self.logger.info(
+                        f"Created code summary for implemented file: {file_path}, summary: {summary[:100]}..."
+                    )
                 else:
                     self.logger.warning(
                         "Missing file path or content for summary generation"
@@ -512,15 +514,14 @@ def _track_file_implementation(self, tool_call: Dict, result: Any):
         except Exception as e:
             self.logger.warning(f"Failed to track file implementation: {e}")
             # Even if tracking fails, try to count based on tool input (but check for duplicates) / 即使跟踪失败，也尝试根据工具输入计数（但检查重复）
-            
+
             file_path = tool_call["input"].get("file_path")
             if file_path and file_path not in self.implemented_files_set:
                 self.implemented_files_set.add(file_path)
                 self.files_implemented_count += 1
                 self.logger.info(
                     f"File implementation counted (emergency fallback): count={self.files_implemented_count}, file={file_path}"
                 )
-           
 
     def _track_dependency_analysis(self, tool_call: Dict, result: Any):
         """
diff --git a/workflows/agents/memory_agent_concise.py b/workflows/agents/memory_agent_concise.py
@@ -483,7 +483,7 @@ def record_tool_result(
         if tool_name == "write_file":
             self.last_write_file_detected = True
             self.should_clear_memory_next = True
-            
+
             # self.logger.info(f"🔄 WRITE_FILE DETECTED: {file_path} - Memory will be cleared in next round")
 
         # Only record specific tools that provide essential information
diff --git a/workflows/code_implementation_workflow.py b/workflows/code_implementation_workflow.py
@@ -363,7 +363,6 @@ async def _pure_code_implementation_loop(
         start_time = time.time()
         max_time = 2400  # 40 minutes
 
-
         # Initialize specialized agents
         code_agent = CodeImplementationAgent(
             self.mcp_agent, self.logger, self.enable_read_tools
@@ -387,7 +386,6 @@ async def _pure_code_implementation_loop(
         # Initialize memory agent with iteration 0
         memory_agent.start_new_round(iteration=0)
 
-
         while iteration < max_iterations:
             iteration += 1
             elapsed_time = time.time() - start_time
@@ -452,8 +450,6 @@ async def _pure_code_implementation_loop(
                 if memory_agent.should_trigger_memory_optimization(
                     messages, code_agent.get_files_implemented_count()
                 ):
-
-
                     # Memory optimization triggered
 
                     # Apply concise memory optimization
@@ -462,9 +458,6 @@ async def _pure_code_implementation_loop(
                     messages = memory_agent.apply_memory_optimization(
                         current_system_message, messages, files_implemented_count
                     )
-         
-
-   
 
                     # Memory optimization completed
 
@@ -481,21 +474,6 @@ async def _pure_code_implementation_loop(
                     "Analysis loop detected and corrective guidance provided"
                 )
 
-            # Round completed
-
-            # # Test summary functionality after every 10 iterations (reduced frequency)
-            # if iteration % 10 == 0 and code_agent.get_files_implemented_count() > 0:
-            #     self.logger.info(f"🧪 Testing summary functionality at iteration {iteration}")
-            #     optimization_success = await code_agent.test_summary_optimization()
-            #     if optimization_success:
-            #         self.logger.info("✅ Summary optimization working correctly")
-            #     else:
-            #         self.logger.warning("⚠️ Summary optimization may not be working")
-
-            # Update memory agent state with current file implementations
-            files_implemented = code_agent.get_files_implemented_count()
-            # memory_agent.sync_with_code_agent(files_implemented)
-
             # Record file implementations in memory agent (for the current round)
             for file_info in code_agent.get_implementation_summary()["completed_files"]:
                 memory_agent.record_file_implementation(file_info["file"])
@@ -564,7 +542,7 @@ async def _initialize_mcp_agent(self, code_directory: str):
             if self.mcp_agent:
                 try:
                     await self.mcp_agent.__aexit__(None, None, None)
-                except:
+                except Exception:
                     pass
                 self.mcp_agent = None
             raise
diff --git a/workflows/code_implementation_workflow_index.py b/workflows/code_implementation_workflow_index.py
@@ -364,10 +364,6 @@ async def _pure_code_implementation_loop(
         start_time = time.time()
         max_time = 2400  # 40 minutes
 
-        # Sliding window configuration
-        WINDOW_SIZE = 1
-        SUMMARY_TRIGGER = 8
-
         # Initialize specialized agents
         code_agent = CodeImplementationAgent(
             self.mcp_agent, self.logger, self.enable_read_tools
@@ -391,11 +387,6 @@ async def _pure_code_implementation_loop(
         # Initialize memory agent with iteration 0
         memory_agent.start_new_round(iteration=0)
 
-        # Preserve initial plan (never compressed)
-        initial_plan_message = messages[0] if messages else None
-
-        # Initial setup logging removed
-
         while iteration < max_iterations:
             iteration += 1
             elapsed_time = time.time() - start_time
@@ -443,14 +434,6 @@ async def _pure_code_implementation_loop(
                     )
 
                 # NEW LOGIC: Check if write_file was called and trigger memory optimization immediately
-                write_file_detected = any(
-                    tool_call["name"] == "write_file"
-                    for tool_call in response["tool_calls"]
-                )
-                # if write_file_detected:
-                #     self.logger.info(f"🔄 write_file detected - preparing memory optimization for next round")
-
-                # Tool results logged via standard logger only
 
                 # Determine guidance based on results
                 has_error = self._check_tool_results_for_errors(tool_results)
@@ -468,27 +451,12 @@ async def _pure_code_implementation_loop(
                 if memory_agent.should_trigger_memory_optimization(
                     messages, code_agent.get_files_implemented_count()
                 ):
-                    # Capture messages before optimization
-                    messages_before_optimization = messages.copy()
-                    messages_before_count = len(messages)
-
-                    # Memory optimization triggered
-
                     # Apply concise memory optimization
                     files_implemented_count = code_agent.get_files_implemented_count()
                     current_system_message = code_agent.get_system_prompt()
                     messages = memory_agent.apply_memory_optimization(
                         current_system_message, messages, files_implemented_count
                     )
-                    messages_after_count = len(messages)
-
-                    compression_ratio = (
-                        (messages_before_count - messages_after_count)
-                        / messages_before_count
-                        * 100
-                        if messages_before_count > 0
-                        else 0
-                    )
 
                     # Memory optimization completed
 
@@ -507,19 +475,6 @@ async def _pure_code_implementation_loop(
 
             # Round completed
 
-            # # Test summary functionality after every 10 iterations (reduced frequency)
-            # if iteration % 10 == 0 and code_agent.get_files_implemented_count() > 0:
-            #     self.logger.info(f"🧪 Testing summary functionality at iteration {iteration}")
-            #     optimization_success = await code_agent.test_summary_optimization()
-            #     if optimization_success:
-            #         self.logger.info("✅ Summary optimization working correctly")
-            #     else:
-            #         self.logger.warning("⚠️ Summary optimization may not be working")
-
-            # Update memory agent state with current file implementations
-            files_implemented = code_agent.get_files_implemented_count()
-            # memory_agent.sync_with_code_agent(files_implemented)
-
             # Record file implementations in memory agent (for the current round)
             for file_info in code_agent.get_implementation_summary()["completed_files"]:
                 memory_agent.record_file_implementation(file_info["file"])
@@ -549,21 +504,12 @@ async def _pure_code_implementation_loop(
                     "Emergency message trim - applying concise memory optimization"
                 )
 
-                # Capture messages before emergency optimization
-                messages_before_emergency = messages.copy()
-                messages_before_count = len(messages)
-
-                # Emergency memory optimization triggered
-
                 # Apply emergency memory optimization
                 current_system_message = code_agent.get_system_prompt()
                 files_implemented_count = code_agent.get_files_implemented_count()
                 messages = memory_agent.apply_memory_optimization(
                     current_system_message, messages, files_implemented_count
                 )
-                messages_after_count = len(messages)
-
-                # Emergency optimization completed
 
         return await self._generate_pure_code_final_report_with_concise_agents(
             iteration, time.time() - start_time, code_agent, memory_agent
@@ -598,7 +544,7 @@ async def _initialize_mcp_agent(self, code_directory: str):
             if self.mcp_agent:
                 try:
                     await self.mcp_agent.__aexit__(None, None, None)
-                except:
+                except Exception:
                     pass
                 self.mcp_agent = None
             raise
