Upload 127 files

tests/test_v102_ui_polish_links_billing.py

@@ -7,7 +7,7 @@ def test_bucket_document_links_use_tree_urls_not_blob_urls():
     assert "/blob/runs/" not in bucket_py
     assert "/blob/runs/" not in runs_js
     assert "def _bucket_file_url" in bucket_py
-    assert "/tree/runs/" in bucket_py
+    assert "tree/{_runs_prefix()}" in bucket_py or "tree/{prefix}" in bucket_py
     assert "bucketRunFileUrl" in runs_js
 
 

tests/test_v123_job_launch_command_and_failure_timeline.py

@@ -20,7 +20,7 @@ def test_v123_jobs_persist_worker_script_to_bucket_before_launch():
     assert "WORKER_SCRIPT_PATH" in jobs_py
     assert '"WORKER_SCRIPT_B64":' not in jobs_py
     assert 'env["WORKER_SCRIPT_B64"]' not in jobs_py
-    assert "runs/{run_id}/_worker.py" in jobs_py
+    assert "{_runs_prefix()}/{run_id}/_worker.py" in jobs_py
 
 
 def test_v123_argument_list_too_long_logs_create_failure_event():

tests/test_v172_fresh_bucket_writes_prescan_readme.py

@@ -0,0 +1,25 @@
+from pathlib import Path
+
+ROOT = Path(__file__).resolve().parents[1]
+
+
+def test_readme_keeps_huggingface_metadata_at_file_start():
+    readme = (ROOT / "README.md").read_text(encoding="utf-8")
+    assert readme.startswith("---\ntitle: Agentic Space Factory\nsdk: docker")
+    assert "hf_oauth: true" in readme.split("---", 2)[1]
+
+
+def test_bucket_writes_use_direct_bucket_object_write_without_virtual_makedirs():
+    bucket = (ROOT / "src" / "bucket.py").read_text(encoding="utf-8")
+    assert "def _write_bucket_text" in bucket
+    assert "fs.pipe_file(candidate, data, mode=\"overwrite\")" in bucket
+    assert "fs.makedirs(parent, exist_ok=True)" not in bucket
+    assert "write_text(_worker_script_bucket_path" in (ROOT / "src" / "jobs.py").read_text(encoding="utf-8")
+
+
+def test_model_prescan_card_uses_calm_premium_overrides():
+    css = (ROOT / "web" / "static" / "app.css").read_text(encoding="utf-8")
+    assert "v172: calmer, premium Model pre-scan card" in css
+    assert "linear-gradient(180deg,rgba(255,255,255,.96),rgba(248,250,252,.92))" in css
+    assert ".prescan-meta{\n  display:grid!important;" in css
+    assert "model-prescan-card.success:before" in css

tests/test_v173_bucket_mount_path_separation.py

@@ -0,0 +1,28 @@
+from pathlib import Path
+
+ROOT = Path(__file__).resolve().parents[1]
+
+
+def test_api_bucket_writes_do_not_makedirs_virtual_runs_prefixes():
+    bucket = (ROOT / "src" / "bucket.py").read_text(encoding="utf-8")
+    assert "def _is_bucket_uri" in bucket
+    assert "def _write_bucket_text" in bucket
+    assert "fs.pipe_file(candidate, data, mode=\"overwrite\")" in bucket
+    assert "fs.makedirs(parent, exist_ok=True)" not in bucket
+    assert "_ensure_bucket_parent" not in bucket
+
+
+def test_worker_script_has_separate_remote_uri_and_job_mount_path():
+    jobs = (ROOT / "src" / "jobs.py").read_text(encoding="utf-8")
+    assert "def _worker_script_bucket_path" in jobs
+    assert "{bucket_uri_from_source(bucket_source)}/{_runs_prefix()}/{run_id}/_worker.py" in jobs
+    assert "def _worker_script_mount_path" in jobs
+    assert "{_runs_mount_path().rstrip('/')}/{run_id}/_worker.py" in jobs
+    assert "write_text(_worker_script_bucket_path" in jobs
+    assert "return _worker_script_mount_path(run_id=run_id)" in jobs
+
+
+def test_legacy_parent_creation_assertion_is_not_positive_anymore():
+    old = (ROOT / "tests" / "test_v172_fresh_bucket_writes_prescan_readme.py").read_text(encoding="utf-8")
+    assert "def test_bucket_writes_create_fresh_run_parent_prefix_before_open" not in old
+    assert "not in bucket" in old

tests/test_v174_bucket_runs_prefix_mount_and_write_fallback.py

@@ -0,0 +1,54 @@
+from pathlib import Path
+from types import SimpleNamespace
+
+import pytest
+
+from src import bucket as bucket_mod
+from src.jobs import _launch_job, _worker_script_bucket_path, _worker_script_mount_path
+
+
+def test_job_mounts_runs_prefix_at_output_runs(monkeypatch):
+    captured = {}
+
+    def fake_run_job(**kwargs):
+        captured.update(kwargs)
+        return SimpleNamespace(id="job-1")
+
+    monkeypatch.setattr("src.jobs.run_job", fake_run_job)
+    _launch_job(token="tok", env={}, bucket_source="alice/space-factory-runs")
+    volumes = captured["volumes"]
+    assert len(volumes) == 1
+    volume = volumes[0]
+    assert getattr(volume, "type") == "bucket"
+    assert getattr(volume, "source") == "alice/space-factory-runs"
+    assert getattr(volume, "path") == "runs"
+    assert getattr(volume, "mount_path") == "/output/runs"
+
+
+def test_worker_script_paths_match_remote_runs_prefix_and_mounted_runs_prefix():
+    assert _worker_script_bucket_path(bucket_source="alice/space-factory-runs", run_id="run-1") == "hf://buckets/alice/space-factory-runs/runs/run-1/_worker.py"
+    assert _worker_script_mount_path(run_id="run-1") == "/output/runs/run-1/_worker.py"
+
+
+class BrokenFs:
+    def write_text(self, *args, **kwargs):
+        raise RuntimeError("repository and revision exist")
+
+    def pipe_file(self, *args, **kwargs):
+        raise RuntimeError("repository and revision exist")
+
+    def open(self, *args, **kwargs):
+        raise RuntimeError("repository and revision exist")
+
+
+def test_bucket_write_falls_back_to_sync_bucket_for_fresh_object(monkeypatch, tmp_path):
+    calls = []
+
+    def fake_sync_bucket(*, source, dest, token=None, quiet=False, **kwargs):
+        calls.append({"source": source, "dest": dest, "token": token, "quiet": quiet})
+        uploaded = Path(source) / "runs" / "run-1" / "_worker.py"
+        assert uploaded.read_text(encoding="utf-8") == "print('ok')"
+
+    monkeypatch.setattr(bucket_mod, "sync_bucket", fake_sync_bucket)
+    bucket_mod._write_bucket_text(BrokenFs(), "hf://buckets/alice/space-factory-runs/runs/run-1/_worker.py", "print('ok')", token="tok")
+    assert calls == [{"source": calls[0]["source"], "dest": "hf://buckets/alice/space-factory-runs", "token": "tok", "quiet": True}]

tests/test_v175_anonymous_eval_archive.py

@@ -0,0 +1,60 @@
+from __future__ import annotations
+
+from src import jobs
+from src.config import Settings
+from src.worker_payload import universal_model_card_worker_script, validate_existing_space_worker_script
+
+
+def eval_settings() -> Settings:
+    return Settings(
+        bucket_name="space-factory-runs",
+        bucket_mount="/output",
+        bucket_runs_prefix="runs",
+        job_flavor="cpu-basic",
+        job_timeout="30m",
+        job_image="python:3.12",
+        eval_enabled=True,
+        eval_bucket_source="huggingface/agentic-space-factory-evals",
+        eval_bucket_path="evals",
+        eval_bucket_mount="/evals",
+        eval_salt="test-salt",
+        eval_include_redacted_tails=False,
+    )
+
+
+def test_eval_bucket_env_is_passed_when_enabled(monkeypatch):
+    monkeypatch.setattr(jobs, "settings", eval_settings())
+    env = jobs._base_env(run_id="universal-20260606-000000-abcd1234", username="alice", bucket_source="alice/space-factory-runs", worker_script_path="/output/runs/x/_worker.py")
+    assert env["ASF_EVAL_ENABLED"] == "true"
+    assert env["ASF_EVAL_BUCKET_SOURCE"] == "huggingface/agentic-space-factory-evals"
+    assert env["ASF_EVAL_BUCKET_PATH"] == "evals"
+    assert env["ASF_EVAL_BUCKET_MOUNT"] == "/evals"
+    assert env["ASF_EVAL_SALT"] == "test-salt"
+
+
+def test_eval_bucket_is_mounted_as_separate_job_volume(monkeypatch):
+    monkeypatch.setattr(jobs, "settings", eval_settings())
+    volumes = jobs._job_volumes("alice/space-factory-runs")
+    rendered = [vars(v) if hasattr(v, "__dict__") else v for v in volumes]
+    text = repr(rendered)
+    assert "alice/space-factory-runs" in text
+    assert "huggingface/agentic-space-factory-evals" in text
+    assert "evals" in text
+    assert "/evals" in text
+
+
+def test_workers_publish_anonymized_eval_records_without_raw_code_or_prompts():
+    script = universal_model_card_worker_script()
+    validation = validate_existing_space_worker_script()
+    for src in (script, validation):
+        assert "def publish_eval_record" in src
+        assert "anonymous_run_id" in src
+        assert "anonymous_user_hash" in src
+        assert "target_space_hash" in src
+        assert "generated_code_stored" in src
+        assert "raw_prompts_stored" in src
+        assert "eval_record.json" in src
+        assert "events_compact.jsonl" in src
+        assert "ASF_EVAL_INCLUDE_MODEL_ID" in src
+    assert "Published anonymized evaluation record" in script
+    assert "Published anonymized validation evaluation record" in validation