code: def _execute_streaming_query_manager_cmd(
      self, cmd: pb2.StreamingQueryManagerCommand
  ) -> pb2.StreamingQueryManagerCommandResult:
      exec_cmd = pb2.Command()
      exec_cmd.streaming_query_manager_command.CopyFrom(cmd)
      (_, properties) = self._session.client.execute_command(exec_cmd)
      return cast(
          pb2.StreamingQueryManagerCommandResult,
          properties["streaming_query_manager_command_result"],
      )
  
imports: from pyspark.sql.connect.utils import check_dependencies
  import json
  import sys
  import pickle
  from typing import TYPE_CHECKING, Any, cast, Dict, List, Optional
  from pyspark.errors import StreamingQueryException, PySparkValueError
  import pyspark.sql.connect.proto
  from pyspark.serializers import CloudPickleSerializer
  from pyspark.sql.connect import proto
  from pyspark.sql.connect.utils import get_python_ver
  from pyspark.sql.streaming import StreamingQueryListener
  from pyspark.sql.streaming.query import StreamingQuery, StreamingQueryManager
  from pyspark.errors.exceptions.connect import StreamingQueryException
  from pyspark.errors import PySparkPicklingError
label_desc: Use image node_id 8 for calling the StreamingQueryManager obj's underlying member method code with example usage: obj._execute_streaming_query_manager_cmd(cmd) and returns: cast