Get the connection storage dict for the current task context.
(self)
| 62 | self._storage_var.set(value) |
| 63 | |
| 64 | def _get_storage(self) -> dict[str, BaseDBAsyncClient]: |
| 65 | """Get the connection storage dict for the current task context.""" |
| 66 | return self._storage_var.get() |
| 67 | |
| 68 | def _set_storage(self, new_storage: dict[str, BaseDBAsyncClient]) -> None: |
| 69 | """Set the connection storage dict. Used for testing purposes.""" |