Skip to content

Commit

Permalink
feat: update frontend heartbeat as well
Browse files Browse the repository at this point in the history
  • Loading branch information
sunng87 committed Jun 10, 2024
1 parent cb2047d commit a890289
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/frontend/src/heartbeat.rs
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ impl HeartbeatTask {
let capture_self = self.clone();
let retry_interval = self.retry_interval;

let _handle = common_runtime::spawn_bg(async move {
let _handle = common_runtime::spawn_hb(async move {
loop {
match resp_stream.message().await {
Ok(Some(resp)) => {
Expand Down Expand Up @@ -132,7 +132,7 @@ impl HeartbeatTask {
addr: self.server_addr.clone(),
});

common_runtime::spawn_bg(async move {
common_runtime::spawn_hb(async move {
let sleep = tokio::time::sleep(Duration::from_millis(0));
tokio::pin!(sleep);

Expand Down

0 comments on commit a890289

Please sign in to comment.