diff --git a/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs b/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs
index f19f4c4ec..98733109b 100644
--- a/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs
+++ b/user-ops-indexer/user-ops-indexer-logic/src/indexer/v06/indexer.rs
@@ -60,7 +60,7 @@ impl<'a, C: PubsubClient> IndexerV06<'a, C> {
                     .subscribe_logs(&filter)
                     .await?
                     .filter_map(|log| {
-                        future::ready(if log.removed == Some(true) {
+                        future::ready(if log.removed != Some(true) {
                             log.transaction_hash
                         } else {
                             None
diff --git a/user-ops-indexer/user-ops-indexer-server/src/indexer.rs b/user-ops-indexer/user-ops-indexer-server/src/indexer.rs
index ef6afc67e..aa77a44d4 100644
--- a/user-ops-indexer/user-ops-indexer-server/src/indexer.rs
+++ b/user-ops-indexer/user-ops-indexer-server/src/indexer.rs
@@ -8,7 +8,7 @@ pub async fn run(
 ) -> Result<(), anyhow::Error> {
     tracing::info!("connecting to rpc");
 
-    let ws_client = Ws::connect_with_reconnects(settings.indexer.rpc_url, 3).await?;
+    let ws_client = Ws::connect_with_reconnects(settings.indexer.rpc_url, 20).await?;
     let client = Provider::new(ws_client);
 
     if settings.indexer.entrypoints.v06 {