Set the event manager. Args: event_manager: The event manager to set. Raises: ServiceConflictError: If the event manager has already been retrieved before.
(self, event_manager: EventManager)
| 74 | return self._event_manager |
| 75 | |
| 76 | def set_event_manager(self, event_manager: EventManager) -> None: |
| 77 | """Set the event manager. |
| 78 | |
| 79 | Args: |
| 80 | event_manager: The event manager to set. |
| 81 | |
| 82 | Raises: |
| 83 | ServiceConflictError: If the event manager has already been retrieved before. |
| 84 | """ |
| 85 | if self._event_manager is event_manager: |
| 86 | # Same instance, no need to anything |
| 87 | return |
| 88 | if self._event_manager: |
| 89 | raise ServiceConflictError(EventManager, event_manager, self._event_manager) |
| 90 | |
| 91 | self._event_manager = event_manager |
| 92 | |
| 93 | def get_storage_client(self) -> StorageClient: |
| 94 | """Get the storage client.""" |