code: def test_handle_limit_offset(self, query_params, expected_xcom_ids):
      url = (
          f"/api/v1/dags/{self.dag_id}/dagRuns/{self.run_id}/taskInstances/{self.task_id}/xcomEntries"
          f"?{query_params}"
      )
      with create_session() as session:
          dagrun = DagRun(
              dag_id=self.dag_id,
              run_id=self.run_id,
              execution_date=self.execution_date_parsed,
              start_date=self.execution_date_parsed,
              run_type=DagRunType.MANUAL,
          )
          session.add(dagrun)
          ti = TaskInstance(
              EmptyOperator(task_id=self.task_id), run_id=self.run_id
          )
          ti.dag_id = self.dag_id
          session.add(ti)
  
      with create_session() as session:
          for i in range(1, 11):
              xcom = XCom(
                  dag_run_id=dagrun.id,
                  key=f"TEST_XCOM_KEY{i}",
                  value=b"null",
                  run_id=self.run_id,
                  task_id=self.task_id,
                  dag_id=self.dag_id,
                  timestamp=self.execution_date_parsed,
              )
              session.add(xcom)
  
      response = self.client.get(
          url, environ_overrides={"REMOTE_USER": "test"}
      )
      assert response.status_code == 200
      assert response.json["total_entries"] == 10
      conn_ids = [
          conn["key"] for conn in response.json["xcom_entries"] if conn
      ]
      assert conn_ids == expected_xcom_ids
  
imports: from __future__ import annotations
  from datetime import timedelta
  from unittest import mock
  import pytest
  from airflow.models.dag import DagModel
  from airflow.models.dagrun import DagRun
  from airflow.models.taskinstance import TaskInstance
  from airflow.models.xcom import BaseXCom, XCom, resolve_xcom_backend
  from airflow.operators.empty import EmptyOperator
  from airflow.security import permissions
  from airflow.utils.dates import parse_execution_date
  from airflow.utils.session import create_session
  from airflow.utils.timezone import utcnow
  from airflow.utils.types import DagRunType
  from tests.test_utils.api_connexion_utils import assert_401, create_user, delete_user
  from tests.test_utils.config import conf_vars
  from tests.test_utils.db import clear_db_dags, clear_db_runs, clear_db_xcom
label_desc: Use image node_id 2 for calling the TestPaginationGetXComEntries obj's underlying member method code with example usage: obj.test_handle_limit_offset(query_params, expected_xcom_ids) without return types