(self, name: str)
| 123 | return True |
| 124 | |
| 125 | async def get(self, name: str) -> bytes | None: |
| 126 | self._purge_if_expired(name) |
| 127 | return self._kv.get(name) |
| 128 | |
| 129 | async def rpush(self, name: str, *values: str) -> int: |
| 130 | _ = name # only TASK_QUEUE used |