def METHOD_NAME(observer, sample_run):
    observer.started_event(**sample_run)
    run = json.loads(
        _get_file_data(
            bucket_name=BUCKET, key=s3_join(observer.dir, "run.json")
        ).decode("utf-8")
    )
    assert run["status"] == "RUNNING"
    observer.interrupted_event(T2, "SERVER_EXPLODED")
    run = json.loads(
        _get_file_data(
            bucket_name=BUCKET, key=s3_join(observer.dir, "run.json")
        ).decode("utf-8")
    )
    assert run["status"] == "SERVER_EXPLODED"