diff --git a/src/tasks/pair-liquidity-info-history-importer/pair-liquidity-info-history-importer.service.ts b/src/tasks/pair-liquidity-info-history-importer/pair-liquidity-info-history-importer.service.ts
index 1d4cbcd..2a38ca8 100644
--- a/src/tasks/pair-liquidity-info-history-importer/pair-liquidity-info-history-importer.service.ts
+++ b/src/tasks/pair-liquidity-info-history-importer/pair-liquidity-info-history-importer.service.ts
@@ -155,6 +155,22 @@ export class PairLiquidityInfoHistoryImporterService {
         let numUpserted = 0;
         for (const current of logsAndEvents) {
           try {
+            // If an error occurred for this log recently, skip block
+            const error =
+              await this.pairLiquidityInfoHistoryErrorDb.getErrorWithinHours(
+                pairWithTokens.id,
+                current.log.block_hash,
+                current.log.call_tx_hash,
+                parseInt(current.log.log_idx),
+                this.WITHIN_HOURS_TO_SKIP_IF_ERROR,
+              );
+            if (error) {
+              this.logger.log(
+                `Skipped log with block hash ${current.log.block_hash} tx hash ${current.log.call_tx_hash} and log index ${current.log.log_idx} due to recent error.`,
+              );
+              continue;
+            }
+
             const succeeding =
               logsAndEvents[logsAndEvents.indexOf(current) + 1];
 
@@ -233,22 +249,6 @@ export class PairLiquidityInfoHistoryImporterService {
               continue;
             }
 
-            // If an error occurred for this log recently, skip block
-            const error =
-              await this.pairLiquidityInfoHistoryErrorDb.getErrorWithinHours(
-                pairWithTokens.id,
-                current.log.block_hash,
-                current.log.call_tx_hash,
-                parseInt(current.log.log_idx),
-                this.WITHIN_HOURS_TO_SKIP_IF_ERROR,
-              );
-            if (error) {
-              this.logger.log(
-                `Skipped log with block hash ${current.log.block_hash} tx hash ${current.log.call_tx_hash} and log index ${current.log.log_idx} due to recent error.`,
-              );
-              continue;
-            }
-
             // Upsert liquidity
             await this.pairLiquidityInfoHistoryDb
               .upsert(liquidityInfo)