import inspect

from EvoScientist.langgraph_dev.http import cancel_recoverable_run


def test_cancel_deletes_run_only_after_execution_exit_receipt():
    source = inspect.getsource(cancel_recoverable_run)
    assert 'initial.get("execution_exited") is not True' in source
    assert "await worker_exit.wait_for_exit" in source
    exit_check = source.index('receipt.get("execution_exited") is True')
    delete = source.index("await Runs.delete")
    assert exit_check < delete
    assert '"checkpoint_cleanup": "completed"' in source