Skip to content

Commit a7fd0fc

Browse files
committed
fix: Make deterministic unfailure restart the BlockStream
1 parent e681ca3 commit a7fd0fc

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

core/src/subgraph/instance_manager.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -625,10 +625,16 @@ where
625625
// There's no point in calling it if we have no current or parent block
626626
// pointers, because there would be: no block to revert to or to search
627627
// errors from (first execution).
628-
let _outcome = ctx
628+
let outcome = ctx
629629
.inputs
630630
.store
631631
.unfail_deterministic_error(&current_ptr, &parent_ptr)?;
632+
633+
if let UnfailOutcome::Unfailed = outcome {
634+
// If the unfail happened, we must restart the BlockStream so the
635+
// reverted block isn't skipped.
636+
break;
637+
}
632638
}
633639
}
634640
}

0 commit comments

Comments
 (0)