code: def _assert_exception_tree_contains_msg(self, exception, msg):
      self.assertTrue(
          msg in exception._message,
          "Exception tree doesn't contain the expected message: %s"
          % msg,
      )
  
imports: from pyspark.sql.tests.streaming.test_streaming import StreamingTestsMixin
  from pyspark.testing.connectutils import ReusedConnectTestCase
label_desc: Use image node_id 1 for calling the StreamingParityTests obj's underlying member method code with example usage: obj._assert_exception_tree_contains_msg(exception, msg) without return types