From ad2d00eed8e9cb4c00246413cd94d0fdc86dace0 Mon Sep 17 00:00:00 2001 From: man0s <95379755+losman0s@users.noreply.github.com> Date: Thu, 4 Jan 2024 20:49:33 +0800 Subject: [PATCH] fix: lint --- observability/indexer/src/commands/index_accounts.rs | 7 +++---- observability/indexer/src/commands/index_transactions.rs | 1 + 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/observability/indexer/src/commands/index_accounts.rs b/observability/indexer/src/commands/index_accounts.rs index 67f17fc7..32b72b41 100644 --- a/observability/indexer/src/commands/index_accounts.rs +++ b/observability/indexer/src/commands/index_accounts.rs @@ -3,7 +3,7 @@ use anyhow::Result; use base64::{engine::general_purpose, Engine}; use chrono::{DateTime, Utc}; use envconfig::Envconfig; -use futures::{future::join_all, SinkExt, StreamExt}; +use futures::{future::join_all, StreamExt}; use google_cloud_default::WithAuthExt; use google_cloud_googleapis::pubsub::v1::PubsubMessage; use google_cloud_pubsub::client::{Client, ClientConfig}; @@ -25,9 +25,8 @@ use yellowstone_grpc_client::GeyserGrpcClient; use yellowstone_grpc_proto::{ geyser::{ subscribe_update::UpdateOneof, CommitmentLevel, SubscribeRequest, - SubscribeRequestFilterAccounts, SubscribeRequestFilterSlots, SubscribeRequestPing, + SubscribeRequestFilterAccounts, SubscribeRequestFilterSlots, }, - tonic::transport::ClientTlsConfig, }; #[derive(Envconfig, Debug, Clone)] @@ -147,7 +146,7 @@ async fn listen_to_updates(ctx: Arc) { }; // Establish streams - let (mut subscribe_request_sink, mut stream) = match geyser_client + let (_, mut stream) = match geyser_client .subscribe_with_request(Some(subscribe_request)) .await { diff --git a/observability/indexer/src/commands/index_transactions.rs b/observability/indexer/src/commands/index_transactions.rs index f7bb6924..a5872bf9 100644 --- a/observability/indexer/src/commands/index_transactions.rs +++ b/observability/indexer/src/commands/index_transactions.rs @@ -21,6 +21,7 @@ use std::{ }, time::Duration, }; +use tonic::Status; use tracing::{debug, error, info, warn}; use uuid::Uuid; use yellowstone_grpc_client::GeyserGrpcClient;