code: def test_gcs_observer_started_event_creates_bucket(
      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",
      }
  
imports: import pytest
  import datetime
  import os
  import json
  from sacred.observers import GoogleCloudStorageObserver
label_desc: Use image node_id 9 for calling a global function with example usage: test_gcs_observer_started_event_creates_bucket(observer, sample_run) without return types