code: def _get_partition_send_func(
      self,
      name,
      tag,
      partitions,
      party_topic_infos,
      src_party_id,
      src_role,
      mq,
      max_message_size,
      conf: dict,
  ):
      def _fn(index, kvs):
          return self._partition_send(
              index=index,
              kvs=kvs,
              name=name,
              tag=tag,
              partitions=partitions,
              party_topic_infos=party_topic_infos,
              src_party_id=src_party_id,
              src_role=src_role,
              mq=mq,
              max_message_size=max_message_size,
              conf=conf,
          )
  
      return _fn
  
imports: import json
  import logging
  import sys
  import typing
  from typing import List
  from fate.arch.computing.api import KVTableContext
  from fate.arch.federation.api import Federation, PartyMeta, TableMeta
  from ._datastream import Datastream
  from ._parties import Party
label_desc: Use image node_id 21 for calling the MessageQueueBasedFederation obj's underlying member method code with example usage: obj._get_partition_send_func(name, tag, partitions, party_topic_infos, src_party_id, src_role, mq, max_message_size, conf) and returns: _fn, self