Skip to content

Commit

Permalink
Cleaning up
Browse files Browse the repository at this point in the history
  • Loading branch information
leboiko committed Jan 21, 2025
1 parent 75af1f4 commit 7984ced
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions envio-indexer/src/app.rs
Original file line number Diff line number Diff line change
@@ -1,15 +1,14 @@
use crate::{error::IndexerError, Args, Network, Output};
use crate::{error::IndexerError, Args, Output};
use aws_sdk_sqs::Client as AWSClient;
use clap::Parser;
use hypersync_client::{net_types::Query, simple_types::Event, Client, ClientConfig};
use hypersync_client::{net_types::Query, simple_types::Event, Client};
use log::info;
use models::raw_logs::RawLog;
use serde::Deserialize;
use serde_json::json;
use shared_utils::postgres::connect_to_db;
use sqlx::PgPool;
use tokio::time::{sleep, Duration};
use url::Url;

/// The environment variables
#[derive(Clone, Deserialize, Debug)]
Expand Down Expand Up @@ -130,7 +129,7 @@ impl App {
let last_observed_block =
RawLog::fetch_last_observed_block(&self.pg_pool, &self.env.indexer_schema).await?;
info!("Last observed block: {:?}", last_observed_block);
sleep(Duration::from_secs(5)).await;

// Get the query for the given network
let mut query = self.query(last_observed_block)?;

Expand Down

0 comments on commit 7984ced

Please sign in to comment.