code: def test_fs_observer_started_event_creates_bucket(
      observer, sample_run
  ):
      _id = observer.started_event(**sample_run)
      run_dir = s3_join(BASEDIR, str(_id))
      assert _bucket_exists(bucket_name=BUCKET)
      assert _key_exists(
          bucket_name=BUCKET, key=s3_join(run_dir, "cout.txt")
      )
      assert _key_exists(
          bucket_name=BUCKET, key=s3_join(run_dir, "config.json")
      )
      assert _key_exists(
          bucket_name=BUCKET, key=s3_join(run_dir, "run.json")
      )
      config = _get_file_data(
          bucket_name=BUCKET, key=s3_join(run_dir, "config.json")
      )
  
      assert json.loads(config.decode("utf-8")) == sample_run["config"]
      run = _get_file_data(
          bucket_name=BUCKET, key=s3_join(run_dir, "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 datetime
  import pytest
  import json
  import os
  from sacred.observers import S3Observer
label_desc: Use image node_id 7 for calling a global function with example usage: test_fs_observer_started_event_creates_bucket(observer, sample_run) without return types