Fix AccessType assigninment in rocksdb.py (#575)

Closes #573.
faust-streaming · Nov 27, 2023 · ad8dd0e · ad8dd0e
1 parent c629e72
commit ad8dd0e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
             )