1

app.py

@@ -16,10 +16,13 @@ def api_submit():
     if not problem:
         return jsonify({'error': 'No problem provided'}), 400
 
+    print(f"[SUBMIT] Received problem ({len(problem)} chars)", flush=True)
     task_id = solver.submit_task(problem)
     if task_id is None:
+        print("[SUBMIT] Server busy", flush=True)
         return jsonify({'error': 'Server is busy, please try again later'}), 503
 
+    print(f"[SUBMIT] Returning task_id: {task_id}", flush=True)
     return jsonify({'task_id': task_id})
 
 
@@ -51,6 +54,12 @@ def api_tasks():
     return jsonify({'tasks': solver.list_tasks()})
 
 
+@app.route('/api/running')
+def api_running():
+    """Return currently running tasks (for recovery after page refresh)."""
+    return jsonify({'tasks': solver.get_running_tasks()})
+
+
 @app.route('/api/debug')
 def api_debug():
     return jsonify(solver.debug_info())

solver.py

@@ -21,19 +21,11 @@ tasks = {}
 tasks_lock = threading.Lock()
 
 
-def _now():
-    return datetime.now(timezone.utc).isoformat()
-
-
-def active_count():
-    with tasks_lock:
-        return sum(1 for t in tasks.values() if t["status"] in ("pending", "running"))
-
-
 def _log(task_id, msg):
-    """Append a line to the task's log file."""
+    """Append a line to the task's log file AND print to stdout."""
     task = tasks.get(task_id)
     if not task:
+        print(f"[{task_id}] {msg}", flush=True)
         return
     log_path = os.path.join(task["workspace"], "solver.log")
     try:
@@ -41,6 +33,16 @@ def _log(task_id, msg):
             f.write(f"[{_now()}] {msg}\n")
     except Exception:
         pass
+    print(f"[{task_id}] {msg}", flush=True)
+
+
+def _now():
+    return datetime.now(timezone.utc).isoformat()
+
+
+def active_count():
+    with tasks_lock:
+        return sum(1 for t in tasks.values() if t["status"] in ("pending", "running"))
 
 
 def submit_task(problem_text):
@@ -88,6 +90,8 @@ def submit_task(problem_text):
     with open(log_path, "w", encoding="utf-8") as f:
         f.write(f"[{_now()}] Task {task_id} created\n")
 
+    print(f"[SUBMIT] Created task {task_id} -> {workspace}", flush=True)
+
     # Spawn background thread
     t = threading.Thread(target=_run_solver, args=(task_id, workspace), daemon=True)
     t.start()
@@ -95,6 +99,7 @@ def submit_task(problem_text):
 
 
 def _run_solver(task_id, workspace):
+    print(f"[{task_id}] _run_solver thread started", flush=True)
     with tasks_lock:
         tasks[task_id].update({"status": "running", "started_at": _now()})
 
@@ -108,8 +113,11 @@ def _run_solver(task_id, workspace):
     proc = None
 
     try:
+        cmd = [sys.executable, os.path.join(workspace, "run.py"), workspace]
+        print(f"[{task_id}] Running: {' '.join(cmd)}", flush=True)
+
         proc = subprocess.Popen(
-            [sys.executable, os.path.join(workspace, "run.py"), workspace],
+            cmd,
             stdout=subprocess.PIPE,
             stderr=subprocess.STDOUT,
             cwd=workspace,
@@ -194,7 +202,11 @@ def _run_solver(task_id, workspace):
                 "finished_at": _now(),
             })
     except Exception as e:
+        import traceback
+        tb = traceback.format_exc()
         _log(task_id, f"Exception: {e}")
+        _log(task_id, tb)
+        print(f"[{task_id}] Traceback:\n{tb}", flush=True)
         with tasks_lock:
             tasks[task_id].update({
                 "status": "error",
@@ -242,8 +254,9 @@ def get_task_logs(task_id, lines=100):
     """Read the last N lines of solver.log."""
     task = tasks.get(task_id)
     if not task:
-        return []
+        return [f"Task {task_id} not found in memory."]
     log_path = os.path.join(task["workspace"], "solver.log")
+    print(f"[LOGS] Reading {log_path} (exists={os.path.exists(log_path)})", flush=True)
     if not os.path.exists(log_path):
         return ["No log file found."]
     try:
@@ -254,6 +267,22 @@ def get_task_logs(task_id, lines=100):
         return [f"Error reading log: {e}"]
 
 
+def get_running_tasks():
+    """Return list of currently running tasks (for frontend recovery after refresh)."""
+    with tasks_lock:
+        return [
+            {
+                "task_id": t["task_id"],
+                "status": t["status"],
+                "phase": t["phase"],
+                "problem": t["problem"],
+                "created_at": t["created_at"],
+            }
+            for t in tasks.values()
+            if t["status"] in ("pending", "running")
+        ]
+
+
 def debug_info():
     """Return filesystem/env debug info for troubleshooting."""
     info = {
@@ -270,14 +299,12 @@ def debug_info():
         "timeout": DEFAULT_TIMEOUT,
         "max_tasks": MAX_TASKS,
         "tasks_count": len(tasks),
-        # Dump all env var keys matching common patterns (values masked)
         "env_keys_found": sorted([
             k for k in os.environ
             if any(pat in k.lower() for pat in [
                 "key", "token", "secret", "anthropic", "hf_", "hugging"
             ])
         ]),
-        # Full env var names (first 30, for debugging HF secret injection)
         "all_env_keys_sample": sorted(os.environ.keys())[:30],
     }
     if os.path.isdir(SOLVER_SRC):

static/solver.html

@@ -54,6 +54,7 @@
     .log-console.visible { display: block; }
     .log-console .log-line { padding: 1px 0; }
     .log-console .log-line:last-child { color: #f9e2af; }
+    .log-console .log-line.loading { color: #585b70; font-style: italic; }
 
     /* Result */
     .result { display: none; margin-top: 16px; }
@@ -189,10 +190,12 @@
       try {
         const resp = await fetch('/api/logs/' + currentTaskId + '?lines=50');
         const data = await resp.json();
+        const el = document.getElementById('log-console');
         if (data.logs && data.logs.length > 0) {
-          const el = document.getElementById('log-console');
           el.innerHTML = data.logs.map(l => `<div class="log-line">${escapeHtml(l)}</div>`).join('');
           el.scrollTop = el.scrollHeight;
+        } else if (!el.querySelector('.loading')) {
+          el.innerHTML = '<div class="log-line loading">Waiting for logs...</div>';
         }
       } catch (e) {}
     }
@@ -358,6 +361,23 @@
         el.textContent = JSON.stringify(data, null, 2);
       })
       .catch(() => {});
+
+    // Recovery: check for running tasks on page load
+    fetch('/api/running')
+      .then(r => r.json())
+      .then(data => {
+        if (data.tasks && data.tasks.length > 0) {
+          const t = data.tasks[0]; // Most recent running task
+          document.getElementById('progress-bar').classList.add('visible');
+          currentTaskId = t.task_id;
+          startTime = Date.now();
+          updateProgress(t.phase || 'starting');
+          fetchLogs();
+          startElapsed();
+          pollStatus();
+        }
+      })
+      .catch(() => {});
   </script>
 </body>
 </html>