def METHOD_NAME(observer, sample_run):
    del sample_run["start_time"]
    sample_run["queue_time"] = T2
    observer.queued_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"] == "QUEUED"