core: check sync status from state instead of making calls to DB

graphprotocol · Feb 20, 2024 · 408a227 · 408a227
1 parent bd1b86d
commit 408a227
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/core/src/subgraph/instance_manager.rs b/core/src/subgraph/instance_manager.rs
@@ -451,12 +451,15 @@ impl<S: SubgraphStore> SubgraphInstanceManager<S> {
             stream: block_stream_metrics,
         };
 
+        let is_deployment_synced = inputs.store.is_deployment_synced().await?;
+
         Ok(SubgraphRunner::new(
             inputs,
             ctx,
             logger.cheap_clone(),
             metrics,
             env_vars,
+            is_deployment_synced,
         ))
     }
 

diff --git a/core/src/subgraph/runner.rs b/core/src/subgraph/runner.rs
@@ -60,13 +60,14 @@ where
         logger: Logger,
         metrics: RunnerMetrics,
         env_vars: Arc<EnvVars>,
+        synced: bool
     ) -> Self {
         Self {
             inputs: Arc::new(inputs),
             ctx,
             state: IndexingState {
                 should_try_unfail_non_deterministic: true,
-                synced: false,
+                synced,
                 skip_ptr_updates_timer: Instant::now(),
                 backoff: ExponentialBackoff::with_jitter(
                     (MINUTE * 2).min(env_vars.subgraph_error_retry_ceil),
@@ -597,7 +598,7 @@ where
 
         // To prevent a buggy pending version from replacing a current version, if errors are
         // present the subgraph will be unassigned.
-        if has_errors && !ENV_VARS.disable_fail_fast && !store.is_deployment_synced().await? {
+        if has_errors && !ENV_VARS.disable_fail_fast && !self.state.synced {
             store
                 .unassign_subgraph()
                 .map_err(|e| BlockProcessingError::Unknown(e.into()))?;
@@ -1311,7 +1312,7 @@ where
 
         // To prevent a buggy pending version from replacing a current version, if errors are
         // present the subgraph will be unassigned.
-        if has_errors && !ENV_VARS.disable_fail_fast && !store.is_deployment_synced().await? {
+        if has_errors && !ENV_VARS.disable_fail_fast && !self.state.synced {
             store
                 .unassign_subgraph()
                 .map_err(|e| BlockProcessingError::Unknown(e.into()))?;