code: def _assert_logged(self, msg):
      if self.log_queue is not None:
          yield
          output = []
          try:
              while True:
                  output.append(
                      self.log_queue.get_nowait().getMessage()
                  )
          except queue.Empty:
              pass
      else:
          with self.assertLogs("concurrent.futures", "CRITICAL") as cm:
              yield
          output = cm.output
      self.assertTrue(any(msg in line for line in output), output)
  
imports: import contextlib
  import logging
  import queue
  import time
  import unittest
  from concurrent.futures._base import BrokenExecutor
  from logging.handlers import QueueHandler
  from test import support
  from .util import ExecutorMixin, create_executor_tests, setup_module
label_desc: Use image node_id 3 for calling the FailingInitializerMixin obj's underlying member method code with example usage: obj._assert_logged(msg) without return types