remove reference to flume

Cargo.lock

@@ -1345,19 +1345,6 @@ dependencies = [
  "miniz_oxide",
 ]
 
-[[package]]
-name = "flume"
-version = "0.10.14"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1657b4441c3403d9f7b3409e47575237dac27b1b5726df654a6ecbf92f0f7577"
-dependencies = [
- "futures-core",
- "futures-sink",
- "nanorand",
- "pin-project",
- "spin 0.9.5",
-]
-
 [[package]]
 name = "fnv"
 version = "1.0.7"
@@ -2257,7 +2244,6 @@ dependencies = [
  "clap 4.1.4",
  "const_env",
  "dashmap",
- "flume",
  "futures",
  "jsonrpsee",
  "lazy_static",
@@ -2397,15 +2383,6 @@ dependencies = [
  "windows-sys 0.42.0",
 ]
 
-[[package]]
-name = "nanorand"
-version = "0.7.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6a51313c5820b0b02bd422f4b44776fbf47961755c74ce64afc73bfad10226c3"
-dependencies = [
- "getrandom 0.2.8",
-]
-
 [[package]]
 name = "native-tls"
 version = "0.2.11"
@@ -3282,7 +3259,7 @@ dependencies = [
  "cc",
  "libc",
  "once_cell",
- "spin 0.5.2",
+ "spin",
  "untrusted",
  "web-sys",
  "winapi",
@@ -4625,15 +4602,6 @@ version = "0.5.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "6e63cff320ae2c57904679ba7cb63280a3dc4613885beafb148ee7bf9aa9042d"
 
-[[package]]
-name = "spin"
-version = "0.9.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7dccf47db1b41fa1573ed27ccf5e08e3ca771cb994f776668c5ebda893b248fc"
-dependencies = [
- "lock_api",
-]
-
 [[package]]
 name = "spki"
 version = "0.5.4"

Cargo.toml

@@ -43,4 +43,3 @@ native-tls = "0.2.11"
 postgres-native-tls = "0.5.0"
 prometheus = "0.13.3"
 lazy_static = "1.4.0"
-flume = "0.10.14"

src/workers/block_listenser.rs

@@ -314,6 +314,7 @@ impl BlockListener {
                     };
 
                     if error_count > 10 {
+                        // retried for 10 times / there should be no block for this slot
                         warn!(
                             "unable to get block at slot {} and commitment {}",
                             slot, commitment_config.commitment