(self)
| 104 | self._current_context = current_context |
| 105 | |
| 106 | def current_context(self) -> Context: |
| 107 | if self._current_context is None: |
| 108 | return None |
| 109 | if self._current_context not in self._contexts: |
| 110 | raise RuntimeError( |
| 111 | f"Failed to get current context: {self._current_context}" |
| 112 | ) |
| 113 | return self._contexts[self._current_context] |
| 114 | |
| 115 | def set_and_write(self, context: Context): |
| 116 | # treat the same endpoint with same services as the same coordinator |
no outgoing calls
no test coverage detected