Correcciones en para la Version 1.1.4 de EduBot

Author: Shuuida

core/executor.py

@@ -13,11 +13,14 @@
 import time
 from typing import Dict, Any
 
-# Use a Manager so queues and shared state can be passed across the worker process.
-_multiprocessing_manager = None
-input_queue = None
-gui_queue = None
-wait_flag = None
+if multiprocessing.current_process().name == 'MainProcess':
+    input_queue = multiprocessing.Queue()
+    gui_queue = multiprocessing.Queue()
+    wait_flag = multiprocessing.Value('b', False)
+else:
+    input_queue = None
+    gui_queue = None
+    wait_flag = None
 
 current_process = None
 current_process_lock = threading.Lock()
@@ -37,15 +40,7 @@ def _global_log_worker():
                     pass
         gevent.sleep(0.05)
 
-def _init_multiprocessing():
-    global _multiprocessing_manager, input_queue, gui_queue, wait_flag
-    if _multiprocessing_manager is None:
-        _multiprocessing_manager = multiprocessing.Manager()
-        input_queue = _multiprocessing_manager.Queue()
-        gui_queue = _multiprocessing_manager.Queue()
-        wait_flag = _multiprocessing_manager.Value('b', False)
-        eel.spawn(_global_log_worker)
-
+# Iniciamos el worker del log solo en el proceso principal
 if multiprocessing.current_process().name == 'MainProcess':
     eel.spawn(_global_log_worker)
 
@@ -143,10 +138,9 @@ def kill_execution() -> bool:
 # EJECUTOR PRINCIPAL
 def execute_user_code(code: str, timeout: int = 5) -> Dict[str, Any]:
     global current_process
-    _init_multiprocessing()
     result = {'success': False, 'output': '', 'error': ''}
 
-    if input_queue is None or gui_queue is None or wait_flag is None or _multiprocessing_manager is None:
+    if input_queue is None or gui_queue is None or wait_flag is None:
         return {'success': False, 'output': '', 'error': 'El entorno de ejecución no está inicializado correctamente.'}
 
     if current_process is not None and current_process.is_alive():
@@ -158,7 +152,8 @@ def execute_user_code(code: str, timeout: int = 5) -> Dict[str, Any]:
         except queue.Empty:
             break
 
-    result_queue = _multiprocessing_manager.Queue()
+    # Usamos la cola nativa en lugar del manager
+    result_queue = multiprocessing.Queue()
     process = multiprocessing.Process(
         target=_execution_target,
         args=(result_queue, input_queue, gui_queue, wait_flag, code)