def METHOD_NAME(self):
    with mock.patch.dict(topic_to_dataset, {self.topic: Dataset.Metrics}):
        consumer = get_query_subscription_consumer(
            self.topic,
            "hi",
            True,
            "earliest",
            1,
            1,
            1,
            DEFAULT_BLOCK_SIZE,
            DEFAULT_BLOCK_SIZE,
            multi_proc=False,
        )
        self.run_test(consumer)