Skip to content

Commit 43e437c

Browse files
committed
fix: deepsource, coderabbit suggestions
1 parent 2b2fe61 commit 43e437c

4 files changed

Lines changed: 171 additions & 130 deletions

File tree

‎src/handlers/http/logstream.rs‎

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -455,9 +455,6 @@ pub async fn put_stream_hot_tier(
455455
hot_tier_manager
456456
.put_hot_tier(&stream_name, &mut hottier, &tenant_id)
457457
.await?;
458-
hot_tier_manager
459-
.spawn_stream_tasks(stream_name.clone(), tenant_id.clone())
460-
.await;
461458

462459
let mut stream_metadata: ObjectStoreFormat = serde_json::from_slice(
463460
&PARSEABLE
@@ -472,7 +469,9 @@ pub async fn put_stream_hot_tier(
472469
.metastore
473470
.put_stream_json(&stream_metadata, &stream_name, &tenant_id)
474471
.await?;
475-
472+
hot_tier_manager
473+
.spawn_stream_tasks(stream_name.clone(), tenant_id.clone())
474+
.await;
476475
Ok((
477476
format!("hot tier set for stream {stream_name}"),
478477
StatusCode::OK,

0 commit comments

Comments
 (0)