tests/test_upstream_refresh_retry_v461.py

from pathlib import Path
ROOT=Path(__file__).resolve().parents[1]

def test_version():
    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.6.1"

def test_probe_returns_status_and_rejects_dead_url():
    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
    assert "probe_status" in py
    assert "upstream download URL is not usable" in py

def test_batch_identity_persisted_on_download_job():
    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
    assert "batch_job_id=batch_job_id" in py
    assert "subtask_id=subtask_id" in py

def test_stream_refreshes_expired_batch_url():
    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
    assert "async def _refresh_job_source_from_batch" in py
    assert "refresh_download_url(batch_job_id,subtask_id)" in py
    assert "upstream download failed after refresh" in py

def test_stream_retries_401_403_404_410():
    py=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
    assert "{401,403,404,410}" in py