code: def _create_list_log_entries_response_mock(messages, token):
      return ListLogEntriesResponse(
          entries=[
              LogEntry(json_payload={"message": message})
              for message in messages
          ],
          next_page_token=token,
      )
  
imports: from __future__ import annotations
  import logging
  from unittest import mock
  from urllib.parse import parse_qs, urlsplit
  import pytest
  from google.cloud.logging import Resource
  from google.cloud.logging_v2.types import ListLogEntriesRequest, ListLogEntriesResponse, LogEntry
  from airflow.providers.google.cloud.log.stackdriver_task_handler import StackdriverTaskHandler
  from airflow.utils import timezone
  from airflow.utils.state import TaskInstanceState
  from tests.test_utils.db import clear_db_dags, clear_db_runs
label_desc: Use image node_id 1 for calling a global function with example usage: _create_list_log_entries_response_mock(messages, token) and returns: ListLogEntriesResponse