Update app.py

app.py

@@ -384,7 +384,7 @@ class SecurePythonExecutor:
         print(f"DEBUG: run_with_timeout called. Client: {websocket_io.websocket.client}")
         
         # Define the synchronous target function to be run in the executor thread
-        def _execute_in_thread_test2(): # Renamed to test2 for clarity
+        def _execute_in_thread_test2(): # Using Test 2 to test sys redirection
             nonlocal result
             original_stdin = sys.stdin
             original_stdout = sys.stdout
@@ -396,7 +396,7 @@ class SecurePythonExecutor:
                 print(f"DEBUG: Executor thread '{threading.current_thread().name}' started. IO redirected.")
                 print("DEBUG: This should now go via websocket_io.write!")
                 
-                # We are still not calling exec here, just testing sys.stdout print
+                # Test print to new sys.stdout
                 print("Hello from redirected stdout!")
                 
                 result['success'] = True
@@ -416,9 +416,8 @@ class SecurePythonExecutor:
         loop = asyncio.get_running_loop()
         try:
             print(f"DEBUG: Scheduling _execute_in_thread_test2 in executor with timeout {self.timeout}s.")
-            # Run the synchronous _execute_in_thread_test2 in a separate thread
             await asyncio.wait_for(
-                loop.run_in_executor(None, _execute_in_thread_test2), # Changed to _execute_in_thread_test2
+                loop.run_in_executor(None, _execute_in_thread_test2), # Call _execute_in_thread_test2
                 timeout=self.timeout
             )
             print("DEBUG: _execute_in_thread_test2 completed via executor.")
@@ -429,9 +428,8 @@ class SecurePythonExecutor:
             try:
                 await websocket_io.write(f"Error: {result['error']}\n")
             except Exception:
-                pass # Ignore if websocket is already closed
+                pass
         except Exception as e:
-            # This catches exceptions from _execute_in_thread_test2 that propagate up
             print(f"ERROR: Unexpected exception from executor: {e}")
             result['error'] = f"Unexpected executor error: {type(e).__name__}: {str(e)}"
             result['success'] = False