code: def test_query_manager_get(self):
      df = self.spark.readStream.format("rate").load()
      for q in self.spark.streams.active:
          q.stop()
      q = df.writeStream.format("noop").start()
  
      self.assertTrue(q.isActive)
      self.assertTrue(q.id == self.spark.streams.get(q.id).id)
  
      q.stop()
  
      self.assertIsNone(self.spark.streams.get(q.id))
  
imports: import os
  import shutil
  import tempfile
  import time
  from pyspark.sql import Row
  from pyspark.sql.functions import lit
  from pyspark.sql.types import StructType, StructField, IntegerType, StringType
  from pyspark.testing.sqlutils import ReusedSQLTestCase
label_desc: Use image node_id 10 for calling the StreamingTestsMixin obj's underlying member method code with example usage: obj.test_query_manager_get() without return types