Upload app.py

app.py

@@ -561,9 +561,9 @@ def create_config_file(model: str, work_dir: str):
             "exploit_ratio": 0.6,
         },
         "evaluator": {
-            "timeout": None,  # Disable timeout to avoid signal handling issues
+            "timeout": 3600,  # 1 hour timeout (effectively disabled, but prevents NoneType arithmetic errors)
             "cascade_evaluation": False,  # Disable cascade to prevent signal errors
-            "parallel_evaluations": 1,  # Single worker
+            "parallel_evaluations": 1,  # Single worker to avoid multiprocessing complexity
             "distributed": False,  # No distributed processing
         }
     }
@@ -673,62 +673,16 @@ def optimize_prompt(initial_prompt: str, dataset_name: str, dataset_split: str,
 
             signal.signal = safe_signal
 
-            # Step 3: Monkey-patch ProcessParallelController
-            import openevolve.process_parallel as pp_module
-            from concurrent.futures import Future
-
-            OriginalProcessController = pp_module.ProcessParallelController
-
-            class NoOpProcessController:
-                def __init__(self, *args, **kwargs):
-                    self.num_workers = 1
-
-                def __enter__(self):
-                    return self
-
-                def __exit__(self, *args):
-                    pass
-
-                def submit(self, func, *args, **kwargs):
-                    # Execute directly and wrap in a completed Future
-                    future = Future()
-                    try:
-                        result = func(*args, **kwargs)
-                        future.set_result(result)
-                    except Exception as e:
-                        future.set_exception(e)
-                    return future
-
-                def map(self, func, *args):
-                    # Execute directly and wrap each result in a Future
-                    futures = []
-                    for a in zip(*args):
-                        future = Future()
-                        try:
-                            result = func(*a)
-                            future.set_result(result)
-                        except Exception as e:
-                            future.set_exception(e)
-                        futures.append(future)
-                    return futures
-
-                def shutdown(self, wait=True):
-                    pass
-
-            pp_module.ProcessParallelController = NoOpProcessController
+            # Run evolution with signal patch in place
+            result = run_evolution(
+                initial_program=initial_prompt_path,
+                evaluator=evaluator_path,
+                config=config_path,
+                output_dir=output_dir
+            )
 
-            try:
-                # Run evolution
-                result = run_evolution(
-                    initial_program=initial_prompt_path,
-                    evaluator=evaluator_path,
-                    config=config_path,
-                    output_dir=output_dir
-                )
-            finally:
-                # Restore everything
-                pp_module.ProcessParallelController = OriginalProcessController
-                signal.signal = original_signal
+            # Restore signal handler
+            signal.signal = original_signal
 
             progress(0.80, desc="Parsing evolution history...")