class_docstr: Manages the publishing of events in a tracker store to an event broker.
  
  Attributes:
      endpoints_path: Path to the endpoints file used to configure the event
          broker and tracker store. If `None`, the default path ('endpoints.yml')
          is used.
      tracker_store: `TrackerStore` to export conversations from.
      event_broker: `EventBroker` to export conversations to.
      requested_conversation_ids: List of conversation IDs requested to be
          processed.
      minimum_timestamp: Minimum timestamp of events that are published.
          If `None`, apply no such constraint.
      maximum_timestamp: Maximum timestamp of events that are published.
          If `None`, apply no such constraint.
class_docstr_tok: ["Manages","the","publishing","of","events","in","a","tracker","store","to","an","event","broker",".","Attributes",":","endpoints_path",":","Path","to","the","endpoints","file","used","to","configure","the","event","broker","and","tracker","store",".","If","`","None","`",",","the","default","path","(","'endpoints.yml","'",")","is","used",".","tracker_store",":","`","TrackerStore","`","to","export","conversations","from",".","event_broker",":","`","EventBroker","`","to","export","conversations","to",".","requested_conversation_ids",":","List","of","conversation","IDs","requested","to","be","processed",".","minimum_timestamp",":","Minimum","timestamp","of","events","that","are","published",".","If","`","None","`",",","apply","no","such","constraint",".","maximum_timestamp",":","Maximum","timestamp","of","events","that","are","published",".","If","`","None","`",",","apply","no","such","constraint","."]
docstr: Get serialised events with added `sender_id` key.
  
  Args:
      events: Events to modify.
      conversation_id: Conversation ID to add to events.
  
  Returns:
      Events with added `sender_id` key.
docstr_tok: ["Get","serialised","events","with","added","`","sender_id","`","key",".","Args",":","events",":","Events","to","modify",".","conversation_id",":","Conversation","ID","to","add","to","events",".","Returns",":","Events","with","added","`","sender_id","`","key","."]
code: def _get_events_for_conversation_id(
      events: List[Dict[Text, Any]], conversation_id: Text
  ) -> List[Dict[Text, Any]]:
      """Get serialised events with added `sender_id` key.
  
      Args:
          events: Events to modify.
          conversation_id: Conversation ID to add to events.
  
      Returns:
          Events with added `sender_id` key.
  
      """
      events_with_conversation_id = []
  
      for event in events:
          event["sender_id"] = conversation_id
          events_with_conversation_id.append(event)
  
      return events_with_conversation_id
  
imports: import logging
  import uuid
  import datetime
  from typing import AsyncIterator, Text, Optional, List, Set, Dict, Any
  from tqdm import tqdm
  import rasa.shared.utils.cli
  import rasa.shared.utils.io
  from rasa.core.brokers.broker import EventBroker
  from rasa.core.brokers.pika import PikaEventBroker
  from rasa.core.constants import RASA_EXPORT_PROCESS_ID_HEADER_NAME
  from rasa.core.tracker_store import TrackerStore
  from rasa.shared.core.trackers import EventVerbosity
  from rasa.exceptions import NoEventsToMigrateError, NoConversationsInTrackerStoreError, PublishingError
label_desc: Use image node_id 6 for calling the Exporter obj's underlying member method code with example usage: obj._get_events_for_conversation_id(events, conversation_id) and returns: events_with_conversation_id