From ad8dd0e68bc9b8d9b1f725bf2eb37a7fc4cbc202 Mon Sep 17 00:00:00 2001 From: William Barnhart Date: Mon, 27 Nov 2023 10:03:59 -0500 Subject: [PATCH] Fix AccessType assigninment in rocksdb.py (#575) Closes #573. --- faust/stores/rocksdb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py index e07579d06..d614b32c4 100644 --- a/faust/stores/rocksdb.py +++ b/faust/stores/rocksdb.py @@ -143,7 +143,7 @@ def open(self, path: Path, *, read_only: bool = False) -> DB: [rocksdict.DBPath(str(path), self.target_file_size_base)] ) db_access_type = ( - rocksdict.AccessType.ReadWrite + rocksdict.AccessType.read_write() if self.ttl is None else rocksdict.AccessType.with_ttl(self.ttl) )