code: def test_fs_observer_queued_event_creates_rundir(dir_obs, sample_run):
      basedir, obs = dir_obs
      _id = obs.queued_event(
          sample_run["ex_info"],
          sample_run["command"],
          sample_run["host_info"],
          datetime.datetime.utcnow(),
          sample_run["config"],
          sample_run["meta_info"],
          sample_run["_id"],
      )
  
      assert _id is not None
      run_dir = basedir.join(str(_id))
      assert run_dir.exists()
      config = json.loads(run_dir.join("config.json").read())
      assert config == sample_run["config"]
  
      run = json.loads(run_dir.join("run.json").read())
      assert run == {
          "experiment": sample_run["ex_info"],
          "command": sample_run["command"],
          "host": sample_run["host_info"],
          "meta": sample_run["meta_info"],
          "status": "QUEUED",
      }
  
imports: import datetime
  import os
  from copy import copy
  import pytest
  import json
  from pathlib import Path
  from sacred.observers.file_storage import FileStorageObserver
  from sacred.metrics_logger import ScalarMetricLogEntry, linearize_metrics
label_desc: Use image node_id 4 for calling a global function with example usage: test_fs_observer_queued_event_creates_rundir(dir_obs, sample_run) without return types