Skip to content

Commit a6026a2

Browse files
fix: exclude internal streams from datasets api
1 parent 9d7c42f commit a6026a2

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

src/prism/logstream/mod.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,16 @@ impl PrismDatasetRequest {
275275
return Ok(None);
276276
}
277277

278+
// exclude internal streams
279+
let is_internal = PARSEABLE.get_stream(&stream).is_ok_and(|stream| {
280+
stream
281+
.get_stream_type()
282+
.eq(&crate::storage::StreamType::Internal)
283+
});
284+
if is_internal {
285+
return Ok(None);
286+
}
287+
278288
// Process stream data
279289
match get_prism_logstream_info(&stream).await {
280290
Ok(info) => Ok(Some(self.build_dataset_response(stream, info).await?)),

0 commit comments

Comments
 (0)