diff --git a/mobile_verifier/src/cli/server.rs b/mobile_verifier/src/cli/server.rs index 37dd8a039..ddf3b2143 100644 --- a/mobile_verifier/src/cli/server.rs +++ b/mobile_verifier/src/cli/server.rs @@ -41,6 +41,7 @@ impl Cmd { concat!(env!("CARGO_PKG_NAME"), "_heartbeat"), ) .deposits(Some(file_upload_tx.clone())) + .auto_commit(false) .roll_time(Duration::minutes(15)) .create() .await?; @@ -52,6 +53,7 @@ impl Cmd { concat!(env!("CARGO_PKG_NAME"), "_speedtest_average"), ) .deposits(Some(file_upload_tx.clone())) + .auto_commit(false) .roll_time(Duration::minutes(15)) .create() .await?; diff --git a/mobile_verifier/src/verifier.rs b/mobile_verifier/src/verifier.rs index c39b3ee66..fdced2ef9 100644 --- a/mobile_verifier/src/verifier.rs +++ b/mobile_verifier/src/verifier.rs @@ -103,6 +103,8 @@ impl VerifierDaemon { } save_last_verified_end_time(&mut transaction, &scheduler.verification_period.end).await?; + let _ = self.heartbeats.commit().await?.await??; + let _ = self.speedtest_avgs.commit().await?.await??; transaction.commit().await?; Ok(())