def METHOD_NAME(observer, sample_run):
    bucket = observer.bucket
    _id = observer.started_event(**sample_run)
    run_dir = gcs_join(BASEDIR, str(_id))
    assert _bucket_exists(bucket)
    assert _file_exists(bucket, run_dir, filename="cout.txt")
    assert _file_exists(bucket, run_dir, filename="config.json")
    assert _file_exists(bucket, run_dir, filename="run.json")
    config = _get_file_data(bucket, run_dir, filename="config.json")
    assert json.loads(config.decode("utf-8")) == sample_run["config"]
    run = _get_file_data(bucket, run_dir, filename="run.json")
    assert json.loads(run.decode("utf-8")) == {
        "experiment": sample_run["ex_info"],
        "command": sample_run["command"],
        "host": sample_run["host_info"],
        "start_time": T1.isoformat(),
        "heartbeat": None,
        "meta": sample_run["meta_info"],
        "resources": [],
        "artifacts": [],
        "status": "RUNNING",
    }