Remove unknown events of parent block when processing a block (#323)

packages/util/src/events.ts

@@ -109,10 +109,6 @@ export class EventWatcher {
 
     await this.publishBlockProgressToSubscribers(blockProgress);
 
-    if (blockProgress.isComplete) {
-      await this._indexer.removeUnknownEvents(blockProgress);
-    }
-
     return this._indexer.getBlockEvents(
       blockProgress.blockHash,
       {

packages/util/src/job-runner.ts

@@ -203,6 +203,9 @@ export class JobRunner {
         }, { priority: newPriority });
 
         throw new Error(message);
+      } else {
+        // Remove the unknown events of the parent block if it is marked complete.
+        await this._indexer.removeUnknownEvents(parentBlock);
       }
     } else {
       blockProgress = parentBlock;