all: remove auto-pausing in auto-graft mode

Author: dwerner

CLAUDE.md

@@ -131,7 +131,7 @@ Tests require:
    ```
 
 ## Current State
-- Version: v0.24.1
+- Version: v0.24.2
 - Active branch: release-v0.24
 - Main branch: main
 - Uncommitted changes in docs/ and config/

docs/auto-graft.md

@@ -163,16 +163,14 @@ Auto-graft will:
 3. Deploy Subgraph A and sync to block 15M
 4. Finally deploy your subgraph starting from block 15M
 
-### Automatic Pausing
+### Dependency Syncing
 
-After each dependency reaches its target block, it's automatically paused to:
-- Prevent unnecessary indexing beyond the graft point
-- Save computational resources
-- Ensure data consistency
+When a dependency reaches its target block, auto-graft will:
+- Log a warning that the graft dependency has reached the required block height
+- Continue indexing past the graft point to ensure the dependency remains available
+- Allow the main subgraph to successfully graft from this dependency
 
-Auto-graft will check for active allocations before pausing a dependency. If a subgraph has an active allocation (meaning it's still serving queries), it will NOT be automatically paused to prevent service disruption. This ensures that customers can continue querying subgraphs that are actively allocated.
-
-*Note: This allocation check was introduced in v0.24.1*
+*Note: Prior to v0.24.2, dependencies were automatically paused after reaching their target block. This behavior was removed to ensure better availability and prevent issues with allocations.*
 
 ## Monitoring Auto-Graft
 
@@ -183,9 +181,9 @@ Monitor these log messages to track auto-graft progress:
 - `"Auto graft deploy subgraph dependencies"` - Process started
 - `"graft dep chain found"` - Dependencies identified
 - `"Dependency subgraph found, checking if it's healthy"` - Existing dependency detected
-- `"Dependency subgraph not found, creating, deploying and pausing..."` - New dependency being deployed
+- `"Dependency subgraph not found, creating, deploying..."` - New dependency being deployed
 - `"Begin syncing subgraph deployment to block"` - Syncing in progress
-- `"Successfully synced"` - Dependency ready
+- `"Graft dependency has reached target block height. Continuing to index past graft point."` - Dependency ready for grafting
 
 ### Checking Dependency Status
 

docs/networks/arbitrum-sepolia.md

@@ -7,8 +7,8 @@ The Graph Network's testnet is on Arbitrum Sepolia (eip155:421614). Sepolia netw
 | Component          | Release                                                                              |
 | ------------------ | ------------------------------------------------------------------------------------ |
 | contracts          | [5.3.3](https://github.com/graphprotocol/contracts/releases/tag/v5.3.3)              |
-| indexer-agent      | [0.24.1](https://github.com/graphprotocol/indexer/releases/tag/v0.24.1)              |
-| indexer-cli        | [0.24.1](https://github.com/graphprotocol/indexer/releases/tag/v0.24.1)              |
+| indexer-agent      | [0.24.2](https://github.com/graphprotocol/indexer/releases/tag/v0.24.2)              |
+| indexer-cli        | [0.24.2](https://github.com/graphprotocol/indexer/releases/tag/v0.24.2)              |
 | indexer-service-rs | [1.0.0](https://github.com/graphprotocol/indexer-rs/releases/tag/v1.0.0)             |
 | tap-agent          | [1.0.0](https://github.com/graphprotocol/indexer-rs/releases/tag/v1.0.0)             |
 | graph-node         | [0.35.1](https://github.com/graphprotocol/graph-node/releases/tag/v0.35.1)           |

lerna.json

@@ -4,5 +4,5 @@
   ],
   "npmClient": "yarn",
   "useWorkspaces": true,
-  "version": "0.24.1"
+  "version": "0.24.2"
 }

packages/indexer-agent/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@graphprotocol/indexer-agent",
-  "version": "0.24.1",
+  "version": "0.24.2",
   "description": "Indexer agent",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -30,7 +30,7 @@
   },
   "dependencies": {
     "@graphprotocol/common-ts": "2.0.11",
-    "@graphprotocol/indexer-common": "^0.24.1",
+    "@graphprotocol/indexer-common": "^0.24.2",
     "@thi.ng/heaps": "^1.3.1",
     "axios": "0.26.1",
     "bs58": "5.0.0",

packages/indexer-agent/src/agent.ts

@@ -6,7 +6,6 @@ import {
   Metrics,
   SubgraphDeploymentID,
   timer,
-  NetworkContracts,
 } from '@graphprotocol/common-ts'
 import {
   ActivationCriteria,
@@ -1257,19 +1256,13 @@ export class Agent {
   }
 
   // TODO: After indexer-service deprecation: Move to be an initialization check inside Network.create()
-  async ensureSubgraphIndexing(
-    deployment: string,
-    networkIdentifier: string,
-    contracts?: NetworkContracts,
-  ) {
+  async ensureSubgraphIndexing(deployment: string, networkIdentifier: string) {
     try {
       // TODO: Check both the local deployment and the external subgraph endpoint
       // Make sure the subgraph is being indexed
       await this.graphNode.ensure(
         `indexer-agent/${deployment.slice(-10)}`,
         new SubgraphDeploymentID(deployment),
-        undefined, // currentAssignments
-        contracts,
       )
 
       // Validate if the Network Subgraph belongs to the current provider's network.
@@ -1295,7 +1288,6 @@ export class Agent {
       await this.ensureSubgraphIndexing(
         network.specification.subgraphs.networkSubgraph.deployment,
         network.specification.networkIdentifier,
-        network.contracts,
       )
     }
     // Epoch subgraph
@@ -1305,15 +1297,13 @@ export class Agent {
       await this.ensureSubgraphIndexing(
         network.specification.subgraphs.epochSubgraph.deployment,
         network.specification.networkIdentifier,
-        network.contracts,
       )
     }
     // TAP subgraph
     if (network.specification.subgraphs.tapSubgraph?.deployment !== undefined) {
       await this.ensureSubgraphIndexing(
         network.specification.subgraphs.tapSubgraph.deployment,
         network.specification.networkIdentifier,
-        network.contracts,
       )
     }
   }

packages/indexer-cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@graphprotocol/indexer-cli",
-  "version": "0.24.1",
+  "version": "0.24.2",
   "description": "Indexer CLI for The Graph Network",
   "main": "./dist/cli.js",
   "files": [
@@ -27,7 +27,7 @@
   },
   "dependencies": {
     "@graphprotocol/common-ts": "2.0.11",
-    "@graphprotocol/indexer-common": "^0.24.1",
+    "@graphprotocol/indexer-common": "^0.24.2",
     "@iarna/toml": "2.2.5",
     "@thi.ng/iterators": "5.1.74",
     "@urql/core": "3.1.0",

packages/indexer-common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@graphprotocol/indexer-common",
-  "version": "0.24.1",
+  "version": "0.24.2",
   "description": "Common library for Graph Protocol indexer components",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/indexer-common/src/graph-node.ts

@@ -1,6 +1,6 @@
 import gql from 'graphql-tag'
 import jayson, { Client as RpcClient } from 'jayson/promise'
-import { Logger, SubgraphDeploymentID, NetworkContracts } from '@graphprotocol/common-ts'
+import { Logger, SubgraphDeploymentID } from '@graphprotocol/common-ts'
 import { Client, createClient } from '@urql/core'
 import {
   INDEXER_ERROR_MESSAGES,
@@ -665,7 +665,6 @@ export class GraphNode {
     name: string,
     deployment: SubgraphDeploymentID,
     currentAssignments?: SubgraphDeploymentAssignment[],
-    contracts?: NetworkContracts,
   ): Promise<void> {
     this.logger.debug('Ensure subgraph deployment is syncing', {
       name,
@@ -694,12 +693,7 @@ export class GraphNode {
         await this.resume(deployment)
       } else {
         // Subgraph deployment not found
-        await this.autoGraftDeployDependencies(
-          deployment,
-          deploymentAssignments,
-          name,
-          contracts,
-        )
+        await this.autoGraftDeployDependencies(deployment, deploymentAssignments, name)
 
         // Create and deploy the subgraph
         this.logger.debug(
@@ -738,7 +732,6 @@ export class GraphNode {
     deployment: SubgraphDeploymentID,
     deploymentAssignments: SubgraphDeploymentAssignment[],
     name: string,
-    contracts?: NetworkContracts,
   ) {
     this.logger.debug('Auto graft deploy subgraph dependencies')
     const { network: subgraphChainName } = await this.subgraphFeatures(deployment)
@@ -795,25 +788,17 @@ export class GraphNode {
             )
           }
         } else if (!dependencyAssignment) {
-          this.logger.debug(
-            'Dependency subgraph not found, creating, deploying and pausing...',
-            {
-              name,
-              deployment: dependency.base.display,
-              block_required: dependency.block,
-            },
-          )
+          this.logger.debug('Dependency subgraph not found, creating, deploying...', {
+            name,
+            deployment: dependency.base.display,
+            block_required: dependency.block,
+          })
           // are we paused at the block we wanted?
 
           await this.create(name)
           await this.deploy(name, dependency.base)
         }
-        await this.syncToBlockAndPause(
-          dependency.block,
-          dependency.base,
-          subgraphChainName,
-          contracts,
-        )
+        await this.syncToBlock(dependency.block, dependency.base, subgraphChainName)
       }
     }
   }
@@ -824,11 +809,10 @@ export class GraphNode {
    * This will resume a paused subgraph if the block height target is higher than the
    * current block height
    */
-  public async syncToBlockAndPause(
+  public async syncToBlock(
     blockHeight: number,
     subgraphDeployment: SubgraphDeploymentID,
     chainName: string | null,
-    contracts?: NetworkContracts,
   ): Promise<void> {
     async function waitForMs(ms: number) {
       return new Promise((resolve) => setTimeout(resolve, ms))
@@ -920,78 +904,14 @@ export class GraphNode {
 
       // Is the graftBaseBlock within the range of the earliest and head of the chain?
       if (chain.latestBlock && chain.latestBlock.number >= blockHeight) {
-        if (!deployed[0].paused) {
-          // Check if there's an active allocation before pausing
-          let hasActiveAllocation = false
-          let checkFailed = false
-
-          // If contracts are provided, check for active allocations
-          if (contracts) {
-            try {
-              // Check if any allocations exist for this subgraph deployment
-              const filter = contracts.staking.filters.AllocationCreated(
-                null, // indexer (any)
-                subgraphDeployment.bytes32, // subgraphDeploymentID
-              )
-              const events = await contracts.staking.queryFilter(filter)
-
-              // Check each allocation to see if it's still active
-              for (const event of events) {
-                const allocationId = event.args?.allocationID
-                if (allocationId) {
-                  const state = await contracts.staking.getAllocationState(allocationId)
-                  // State 1 means Active allocation
-                  if (state === 1) {
-                    hasActiveAllocation = true
-                    break
-                  }
-                }
-              }
-
-              if (hasActiveAllocation) {
-                this.logger.warn(`Subgraph has active allocation, not going to pause`, {
-                  subgraph: subgraphDeployment.ipfsHash,
-                  blockHeight,
-                  indexingStatus,
-                })
-              }
-            } catch (error) {
-              checkFailed = true
-              this.logger.error(`Failed to check allocation state, not going to pause`, {
-                subgraph: subgraphDeployment.ipfsHash,
-                error,
-              })
-            }
-          } else {
-            // No contracts provided, skip pause for safety
-            this.logger.warn(
-              `No contracts provided to check allocation state, not going to pause`,
-              {
-                subgraph: subgraphDeployment.ipfsHash,
-                blockHeight,
-              },
-            )
-            checkFailed = true
-          }
-
-          // Only pause if we successfully checked and found no active allocations
-          if (!hasActiveAllocation && !checkFailed) {
-            this.logger.debug(
-              `Subgraph synced to block! Pausing as requirement is met.`,
-              {
-                subgraph: subgraphDeployment.ipfsHash,
-                indexingStatus,
-              },
-            )
-            // pause the subgraph to prevent further indexing
-            await this.pause(subgraphDeployment)
-          }
-        } else {
-          this.logger.debug(`Subgraph already paused and synced to block.`, {
+        this.logger.warn(
+          `Graft dependency has reached target block height. Continuing to index past graft point.`,
+          {
             subgraph: subgraphDeployment.ipfsHash,
-            indexingStatus,
-          })
-        }
+            blockHeight,
+            currentBlock: chain.latestBlock.number,
+          },
+        )
         break
       }
 

packages/indexer-common/src/indexer-management/allocations.ts

@@ -433,7 +433,6 @@ export class AllocationManager {
           `indexer-agent/${action.deploymentID!.slice(-10)}`,
           new SubgraphDeploymentID(action.deploymentID!),
           currentAssignments,
-          this.network.contracts,
         ),
       {
         stopOnError: false,