Skip to content

Commit 9b088fe

Browse files
committed
fix: Add async_supported property to RedisOnlineStore
Signed-off-by: ntkathole <[email protected]>
1 parent a6a2a81 commit 9b088fe

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

  • sdk/python/feast/infra/online_stores

‎sdk/python/feast/infra/online_stores/redis.py‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
)
4343
from feast.infra.online_stores.online_store import OnlineStore
4444
from feast.infra.registry.base_registry import BaseRegistry
45+
from feast.infra.supported_async_methods import SupportedAsyncMethods
4546
from feast.online_response import OnlineResponse
4647
from feast.protos.feast.types.EntityKey_pb2 import EntityKey as EntityKeyProto
4748
from feast.protos.feast.types.Value_pb2 import RepeatedValue
@@ -118,6 +119,10 @@ class RedisOnlineStore(OnlineStore):
118119
None
119120
)
120121

122+
@property
123+
def async_supported(self) -> SupportedAsyncMethods:
124+
return SupportedAsyncMethods(read=True, write=True)
125+
121126
def delete_entity_values(self, config: RepoConfig, join_keys: List[str]):
122127
client = self._get_client(config.online_store)
123128
deleted_count = 0

0 commit comments

Comments
 (0)