Fetch conversation IDs in `self.tracker_store`. Returns: A set of conversation IDs in `self.tracker_store`. Raises: `NoConversationsInTrackerStoreError` if `conversation_ids_in_tracker_store` is empty.
(self)
| 135 | self.event_broker.publish(event) |
| 136 | |
| 137 | async def _get_conversation_ids_in_tracker(self) -> Set[Text]: |
| 138 | """Fetch conversation IDs in `self.tracker_store`. |
| 139 | |
| 140 | Returns: |
| 141 | A set of conversation IDs in `self.tracker_store`. |
| 142 | |
| 143 | Raises: |
| 144 | `NoConversationsInTrackerStoreError` if |
| 145 | `conversation_ids_in_tracker_store` is empty. |
| 146 | |
| 147 | """ |
| 148 | conversation_ids_in_tracker_store = set(await self.tracker_store.keys()) |
| 149 | |
| 150 | if conversation_ids_in_tracker_store: |
| 151 | return conversation_ids_in_tracker_store |
| 152 | |
| 153 | raise NoConversationsInTrackerStoreError( |
| 154 | "Could not find any conversations in connected tracker store. " |
| 155 | "Please validate your `endpoints.yml` and make sure the defined " |
| 156 | "tracker store exists. Exiting." |
| 157 | ) |
| 158 | |
| 159 | def _validate_all_requested_ids_exist( |
| 160 | self, conversation_ids_in_tracker_store: Set[Text] |
no test coverage detected