rasa/core/training/interactive.py
async def _fetch_events(sender_ids: List[Union[Text, List[Event]]],
                        endpoint: EndpointConfig
                        ) -> List[List[Event]]:
    """Retrieve all event trackers from the endpoint for all sender ids."""

    event_sequences = []
    for sender_id in sender_ids:
        if isinstance(sender_id, str):
            tracker = await retrieve_tracker(endpoint, sender_id)
            evts = tracker.get("events", [])

            for conversation in _split_conversation_at_restarts(evts):
                parsed_events = events.deserialise_events(conversation)
                event_sequences.append(parsed_events)
        else:
            event_sequences.append(sender_id)
    return event_sequences
Retrieve all event trackers from the endpoint for all sender ids.
Retrieve all event trackers from the endpoint for all sender ids.
Retrieve all event trackers from the endpoint for all sender ids .
async def _fetch_events(sender_ids: List[Union[Text, List[Event]]],
                        endpoint: EndpointConfig
                        ) -> List[List[Event]]:
    event_sequences = []
    for sender_id in sender_ids:
        if isinstance(sender_id, str):
            tracker = await retrieve_tracker(endpoint, sender_id)
            evts = tracker.get("events", [])
            for conversation in _split_conversation_at_restarts(evts):
                parsed_events = events.deserialise_events(conversation)
                event_sequences.append(parsed_events)
        else:
            event_sequences.append(sender_id)
    return event_sequences
async def _fetch_events ( sender_ids : List [ Union [ Text , List [ Event ] ] ] , endpoint : EndpointConfig ) -> List [ List [ Event ] ] : event_sequences = [ ] for sender_id in sender_ids : if isinstance ( sender_id , str ) : tracker = await retrieve_tracker ( endpoint , sender_id ) evts = tracker . get ( "events" , [ ] ) for conversation in _split_conversation_at_restarts ( evts ) : parsed_events = events . deserialise_events ( conversation ) event_sequences . append ( parsed_events ) else : event_sequences . append ( sender_id ) return event_sequences
Retrieve all event trackers from the endpoint for all sender ids.
Retrieve all event trackers from the endpoint for all sender ids .
"""Retrieve all event trackers from the endpoint for all sender ids."""
sender_ids
List[Union[Text, List[Event]]]
endpoint
EndpointConfig