Upload 27 files

tests/test_v52_ui_fixes.py

@@ -39,6 +39,6 @@ def test_runs_explorer_is_limited_to_five_rows_with_pagination():
 
 def test_progress_endpoint_uses_view_model_links_for_job_url():
     app_py = Path("app.py").read_text(encoding="utf-8")
-    assert '"version": "v58-stable-refresh-pi-stdout-bucket-links"' in app_py
+    assert '"version": "v60-cancel-persist-delete-run"' in app_py
     assert 'view = build_run_view_model(run_id, bundle, bucket_source=bucket_source)' in app_py
     assert '"links": view.get("links")' in app_py

tests/test_v57_live_pi_traces.py

@@ -15,7 +15,7 @@ def test_bucket_and_progress_endpoint_expose_pi_live_log():
     app = Path("app.py").read_text(encoding="utf-8")
     assert '"pi_live_log": _safe_read_text' in bucket
     assert '"pi_output_log": _safe_read_text' in bucket
-    assert '"pi_live_log": (bundle.get("pi_live_log")' in app
+    assert '"pi_live_log": pi_stdout[-12000:]' in app
 
 
 def test_ui_has_pi_live_trace_panel_and_renderer():
@@ -30,4 +30,4 @@ def test_ui_has_pi_live_trace_panel_and_renderer():
 
 
 def test_app_version_v57():
-    assert '"version": "v58-stable-refresh-pi-stdout-bucket-links"' in Path("app.py").read_text(encoding="utf-8")
+    assert '"version": "v60-cancel-persist-delete-run"' in Path("app.py").read_text(encoding="utf-8")

tests/test_v58_stable_refresh_pi_stdout.py

@@ -26,26 +26,6 @@ def test_pi_live_panel_is_stdout_not_trace_jsonl():
     assert "No Pi stdout yet" in js
 
 
-def test_active_run_uses_bucket_file_links_instead_of_duplicate_space_job_buttons():
-    html = Path("web/index.html").read_text(encoding="utf-8")
-    active = html.split('id="activeRunPanel"', 1)[1].split('id="runsExplorerPanel"', 1)[0]
-    assert 'id="openRunState"' in active
-    assert 'id="openRunReport"' in active
-    assert 'id="openRunLogs"' in active
-    assert 'id="openRunTraces"' in active
-    assert 'id="openJob"' not in active
-    assert 'id="openSpace"' not in active
-    assert 'id="openSettings"' not in active
-
-
-def test_bucket_file_links_are_rendered_from_run_and_bucket():
-    js = Path("web/static/progress.js").read_text(encoding="utf-8")
-    assert "bucketBlobUrl" in js
-    assert "bucketTreeUrl" in js
-    assert "openRunState" in js
-    assert "openRunLogs" in js
-    assert "openRunTraces" in js
-
 
 def test_app_version_v58():
-    assert '"version": "v58-stable-refresh-pi-stdout-bucket-links"' in Path("app.py").read_text(encoding="utf-8")
+    assert '"version": "v60-cancel-persist-delete-run"' in Path("app.py").read_text(encoding="utf-8")

tests/test_v59_job_log_progress_clean.py

@@ -0,0 +1,54 @@
+from pathlib import Path
+
+from app import _events_from_job_logs, _merge_events, _normalize_job_stage
+
+
+def test_progress_endpoint_polls_hf_job_logs_and_extracts_worker_events():
+    app_py = Path("app.py").read_text(encoding="utf-8")
+    assert "inspect_job_safe(job_id" in app_py
+    assert "fetch_recent_logs_safe(job_id" in app_py
+    assert "_events_from_job_logs(job_logs)" in app_py
+    assert "_merge_events(bundle.get" in app_py
+    assert '"job_logs": job_logs[-20000:]' in app_py
+    assert '"job_log_events_count": len(job_log_events)' in app_py
+
+
+def test_job_log_event_parser_extracts_json_events_from_logs():
+    logs = """noise
+{"ts":"2026-06-02T10:00:00+00:00","step":"pi_run","status":"running","message":"Pi is still working"}
+prefix {"ts":"2026-06-02T10:00:01+00:00","step":"upload_files","status":"success","message":"Uploaded"}
+not json
+"""
+    events = _events_from_job_logs(logs)
+    assert [event["step"] for event in events] == ["pi_run", "upload_files"]
+
+
+def test_merge_events_deduplicates_bucket_and_job_log_events():
+    event = {"ts": "t", "step": "pi_run", "status": "running", "message": "same"}
+    merged = _merge_events([event], [dict(event), {"ts": "t2", "step": "done", "status": "success"}])
+    assert len(merged) == 2
+
+
+def test_job_stage_normalization():
+    assert _normalize_job_stage("JobStage.RUNNING") == "running"
+    assert _normalize_job_stage("COMPLETED") == "success"
+    assert _normalize_job_stage("CANCELLED") == "cancelled"
+
+
+def test_active_run_only_keeps_cancel_button():
+    html = Path("web/index.html").read_text(encoding="utf-8")
+    active = html.split('id="activeRunPanel"', 1)[1].split('id="runsExplorerPanel"', 1)[0]
+    assert 'id="cancelRun"' in active
+    for removed in ['id="openArtifacts"', 'id="openRunState"', 'id="openRunReport"', 'id="openRunLogs"', 'id="openRunTraces"', 'id="openJob"', 'id="openSpace"', 'id="openSettings"']:
+        assert removed not in active
+
+
+def test_progress_renderer_no_longer_sets_active_run_link_buttons():
+    js = Path("web/static/progress.js").read_text(encoding="utf-8")
+    assert "renderActiveBucketLinks" not in js
+    assert "openRunState" not in js
+    assert "setLink('openJob'" not in js
+
+
+def test_app_version_v59():
+    assert '"version": "v60-cancel-persist-delete-run"' in Path("app.py").read_text(encoding="utf-8")

tests/test_v60_cancel_persist_delete_run.py

@@ -0,0 +1,47 @@
+from pathlib import Path
+
+
+def test_cancel_uses_hf_jobs_cancel_api_and_persists_bucket_state():
+    jobs = Path("src/jobs.py").read_text(encoding="utf-8")
+    app = Path("app.py").read_text(encoding="utf-8")
+    bucket = Path("src/bucket.py").read_text(encoding="utf-8")
+    assert "from huggingface_hub import Volume, cancel_job" in jobs
+    assert "cancel_job(job_id=job_id, namespace=namespace, token=token)" in jobs
+    assert '"cancel_requested": True' in app
+    assert '"cancelled_at": cancelled_at' in app
+    assert 'write_json(f"{paths.root}/cancel.json"' in app
+    assert 'append_run_event(' in app
+    assert "def append_run_event" in bucket
+
+
+def test_delete_run_endpoint_and_bucket_helper_exist():
+    app = Path("app.py").read_text(encoding="utf-8")
+    bucket = Path("src/bucket.py").read_text(encoding="utf-8")
+    assert '@fastapi_app.delete("/api/runs/{run_id}")' in app
+    assert "delete_run_folder(run_id" in app
+    assert "def delete_run_folder" in bucket
+    assert ".rm(paths.root, recursive=True)" in bucket
+
+
+def test_selected_run_has_delete_button_and_frontend_delete_flow():
+    html = Path("web/index.html").read_text(encoding="utf-8")
+    runs = Path("web/static/runs.js").read_text(encoding="utf-8")
+    api = Path("web/static/api.js").read_text(encoding="utf-8")
+    assert 'id="deleteSelectedRun"' in html
+    assert "Delete run from bucket" in html
+    assert "async function deleteSelectedRun" in runs
+    assert "/api/runs/${encodeURIComponent(runId)}" in runs
+    assert "async function apiDelete" in api
+
+
+def test_active_run_still_only_has_cancel_button():
+    html = Path("web/index.html").read_text(encoding="utf-8")
+    active = html.split('id="activeRunPanel"', 1)[1].split('id="runsExplorerPanel"', 1)[0]
+    assert 'id="cancelRun"' in active
+    assert 'id="deleteSelectedRun"' not in active
+    for removed in ['id="openArtifacts"', 'id="openRunState"', 'id="openRunReport"', 'id="openRunLogs"', 'id="openRunTraces"', 'id="openJob"', 'id="openSpace"', 'id="openSettings"']:
+        assert removed not in active
+
+
+def test_app_version_v60():
+    assert '"version": "v60-cancel-persist-delete-run"' in Path("app.py").read_text(encoding="utf-8")