core: Flush the store on fatal errors

We have runner tests failing frequently because the store seems to get
dropped while it still has pending writes. This change attempts to prevent
that by flushing the store when we encounter a fatal error.

Author: lutter

core/src/subgraph/runner.rs

@@ -498,6 +498,9 @@ where
         // In this scenario the only entity that is stored/transacted is the PoI,
         // all of the others are discarded.
         if has_errors && self.inputs.errors_are_fatal() {
+            if let Err(e) = self.inputs.store.flush().await {
+                error!(logger, "Failed to flush store after fatal errors"; "error" => format!("{:#}", e));
+            }
             // Only the first error is reported.
             return Err(ProcessingError::Deterministic(Box::new(
                 first_error.unwrap(),