code: def _consume_ack(self, channel_info, id):
      channel_info.ack(message=id)
  
imports: import logging
  from typing import List, Optional
  from fate.arch.federation.api import PartyMeta
  from fate.arch.federation.message_queue import MessageQueueBasedFederation
  from ._mq_channel import DEFAULT_CLUSTER, DEFAULT_SUBSCRIPTION_NAME, DEFAULT_TENANT, MQChannel
  from ._pulsar_manager import PulsarManager
label_desc: Use image node_id 10 for calling the PulsarFederation obj's underlying member method code with example usage: obj._consume_ack(channel_info, id) without return types