add postgres kvstoreimpl

This commit is contained in:
Dinesh Yeduguru 2024-11-05 10:30:07 -08:00
parent 8de845a96d
commit 726fd15dc4
3 changed files with 114 additions and 1 deletions

View file

@ -43,7 +43,9 @@ async def kvstore_impl(config: KVStoreConfig) -> KVStore:
impl = SqliteKVStoreImpl(config)
elif config.type == KVStoreType.postgres.value:
raise NotImplementedError()
from .postgres import PostgresKVStoreImpl
impl = PostgresKVStoreImpl(config)
else:
raise ValueError(f"Unknown kvstore type {config.type}")