code: def test_run_waits_for_running_queue_observer():
      queue_observer_with_long_interval = QueueObserver(
          mock.MagicMock(), interval=1, retry_interval=0.01
      )
  
      ex = Experiment("ator3000")
      ex.observers.append(queue_observer_with_long_interval)
  
      @ex.main
      def main():
          print("do nothing")
  
      ex.run()
      assert (
          queue_observer_with_long_interval._covered_observer.method_calls[
              -1
          ][
              0
          ]
          == "completed_event"
      )
  
file_path: sacred/tests/test_observers/test_queue_observer.py
imports: from collections import OrderedDict
  from sacred.observers.queue import QueueObserver
  from sacred import Experiment
  import mock
  import pytest
label_desc: Use image node_id 6 for calling a global function with example usage: test_run_waits_for_running_queue_observer() without return types