replaced to get_stream

nikhilsinhaparseable · nikhilsinhaparseable · commit 264ccf306aab · 2025-04-14T07:16:13.000-04:00
diff --git a/src/handlers/http/modal/ingest/ingestor_logstream.rs b/src/handlers/http/modal/ingest/ingestor_logstream.rs
@@ -72,7 +72,7 @@ pub async fn delete(stream_name: Path<String>) -> Result<impl Responder, StreamE
     }
 
     // Delete from staging
-    let stream_dir = PARSEABLE.get_or_create_stream(&stream_name);
+    let stream_dir = PARSEABLE.get_stream(&stream_name)?;
     if fs::remove_dir_all(&stream_dir.data_path).is_err() {
         warn!(
             "failed to delete local data for stream {}. Clean {} manually",

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ pub async fn delete(stream_name: Path<String>) -> Result<impl Responder, StreamE`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`// Delete from staging`
`75`		`- let stream_dir = PARSEABLE.get_or_create_stream(&stream_name);`
	`75`	`+ let stream_dir = PARSEABLE.get_stream(&stream_name)?;`
`76`	`76`	`if fs::remove_dir_all(&stream_dir.data_path).is_err() {`
`77`	`77`	`warn!(`
`78`	`78`	`"failed to delete local data for stream {}. Clean {} manually",`