Skip to content
This repository has been archived by the owner on Aug 30, 2024. It is now read-only.

Commit

Permalink
fix: clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
ratankaliani committed Aug 5, 2024
1 parent f6e4c2b commit e239c6f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions bin/blobstreamx.rs
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,6 @@ impl BlobstreamXOperator {
/// Process an iteration of the operator loop.
async fn process_loop_iteration(
&self,
loop_delay_mins: u64,
block_interval: u64,
data_commitment_max: u64,
) -> Result<()> {
Expand Down Expand Up @@ -306,11 +305,12 @@ impl BlobstreamXOperator {
info!("Starting BlobstreamX operator");

loop {
if let Err(_) = tokio::time::timeout(
if tokio::time::timeout(
tokio::time::Duration::from_secs(OPERATOR_LOOP_TIMEOUT_SECS),
self.process_loop_iteration(loop_delay_mins, block_interval, data_commitment_max),
self.process_loop_iteration(block_interval, data_commitment_max),
)
.await
.is_err()
{
error!("Loop iteration timed out after 3 minutes. Restarting...");
}
Expand Down

0 comments on commit e239c6f

Please sign in to comment.