code: def test_send_offset_fetch_request_versions(
      patched_coord, partitions, api_version, req_type
  ):
      # assuming fixture sets coordinator=0, least_loaded_node=1
      expect_node = 0
      patched_coord.config["api_version"] = api_version
  
      patched_coord._send_offset_fetch_request(partitions)
      (node, request), _ = patched_coord._client.send.call_args
      assert node == expect_node, "Unexpected coordinator node"
      assert isinstance(request, req_type)
  
imports: from __future__ import absolute_import
  import time
  import pytest
  from kafka.client_async import KafkaClient
  from kafka.consumer.subscription_state import SubscriptionState, ConsumerRebalanceListener
  from kafka.coordinator.assignors.range import RangePartitionAssignor
  from kafka.coordinator.assignors.roundrobin import RoundRobinPartitionAssignor
  from kafka.coordinator.assignors.sticky.sticky_assignor import StickyPartitionAssignor
  from kafka.coordinator.base import Generation, MemberState, HeartbeatThread
  from kafka.coordinator.consumer import ConsumerCoordinator
  from kafka.coordinator.protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment
  import kafka.errors
  from kafka.future import Future
  from kafka.metrics import Metrics
  from kafka.protocol.commit import OffsetCommitRequest, OffsetCommitResponse, OffsetFetchRequest, OffsetFetchResponse
  from kafka.protocol.metadata import MetadataResponse
  from kafka.structs import OffsetAndMetadata, TopicPartition
  from kafka.util import WeakMethod
label_desc: Use image node_id 31 for calling a global function with example usage: test_send_offset_fetch_request_versions(patched_coord, partitions, api_version, req_type) without return types