Hotfix backfill indexer db leaks (#4371)

* Hotfix backfill indexer db leaks * lint
AudiusProject · Nov 16, 2022 · 721cb89 · 721cb89
1 parent 9bcbd0d
commit 721cb89
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 20 deletions.
diff --git a/discovery-provider/src/tasks/index_rewards_manager_backfill.py b/discovery-provider/src/tasks/index_rewards_manager_backfill.py
@@ -760,15 +760,17 @@ def index_rewards_manager_backfill(self):
         else:
             stop_sig = stop_sig[0]
 
-    if not stop_sig:
-        logger.info(
-            f"index_rewards_manager_backfill.py | No stop_sig found: {stop_sig}"
-        )
-        return
+        if not stop_sig:
+            logger.info(
+                f"index_rewards_manager_backfill.py | No stop_sig found: {stop_sig}"
+            )
+            return
 
-    if check_if_backfilling_complete(session, solana_client_manager, redis):
-        logger.info("index_rewards_manager_backfill.py | Backfill indexing complete!")
-        return
+        if check_if_backfilling_complete(session, solana_client_manager, redis):
+            logger.info(
+                "index_rewards_manager_backfill.py | Backfill indexing complete!"
+            )
+            return
 
     try:
         # Attempt to acquire lock - do not block if unable to acquire

diff --git a/discovery-provider/src/tasks/index_spl_token_backfill.py b/discovery-provider/src/tasks/index_spl_token_backfill.py
@@ -652,13 +652,15 @@ def index_spl_token_backfill(self):
         else:
             stop_sig = stop_sig[0]
 
-    if not stop_sig:
-        logger.info(f"index_spl_token_backfill.py | Error with stop_sig: {stop_sig}")
-        return
+        if not stop_sig:
+            logger.info(
+                f"index_spl_token_backfill.py | Error with stop_sig: {stop_sig}"
+            )
+            return
 
-    if check_if_backfilling_complete(session, solana_client_manager, redis):
-        logger.info("index_spl_token_backfill.py | Backfill indexing complete!")
-        return
+        if check_if_backfilling_complete(session, solana_client_manager, redis):
+            logger.info("index_spl_token_backfill.py | Backfill indexing complete!")
+            return
 
     try:
         # Attempt to acquire lock - do not block if unable to acquire

diff --git a/discovery-provider/src/tasks/index_user_bank_backfill.py b/discovery-provider/src/tasks/index_user_bank_backfill.py
@@ -684,13 +684,13 @@ def index_user_bank_backfill(self):
         else:
             stop_sig = stop_sig[0]
 
-    if not stop_sig:
-        logger.info(f"index_user_bank_backfill.py | No stop_sig found: {stop_sig}")
-        return
+        if not stop_sig:
+            logger.info(f"index_user_bank_backfill.py | No stop_sig found: {stop_sig}")
+            return
 
-    if check_if_backfilling_complete(session, solana_client_manager, redis):
-        logger.info("index_user_bank_backfill.py | Backfill indexing complete!")
-        return
+        if check_if_backfilling_complete(session, solana_client_manager, redis):
+            logger.info("index_user_bank_backfill.py | Backfill indexing complete!")
+            return
 
     try:
         # Attempt to acquire lock - do not block if unable to acquire