We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 620eecb commit fb66a93Copy full SHA for fb66a93
server/src/storage/object_storage.rs
@@ -185,7 +185,8 @@ pub trait ObjectStorage: Sync + 'static {
185
&self,
186
stream_name: &str,
187
) -> Result<Schema, ObjectStorageError> {
188
- let schema_path = RelativePathBuf::from_iter([stream_name, SCHEMA_FILE_NAME]);
+ let schema_path =
189
+ RelativePathBuf::from_iter([stream_name, STREAM_ROOT_DIRECTORY, SCHEMA_FILE_NAME]);
190
let schema_map = self.get_object(&schema_path).await?;
191
Ok(serde_json::from_slice(&schema_map)?)
192
}
@@ -223,6 +224,7 @@ pub trait ObjectStorage: Sync + 'static {
223
224
let bytes = self
225
.get_object(&RelativePathBuf::from_iter([
226
stream_name,
227
+ STREAM_ROOT_DIRECTORY,
228
STREAM_METADATA_FILE_NAME,
229
]))
230
.await?;
0 commit comments