agent,common: Use new subgraph pausing mechanism

- Use subgraph_pause JSON-RPC method instead of subgraph_reassign, which explicitly pauses subgraph instead of virtually pausing it by moving it to a non-existent index node
graphprotocol · Mar 8, 2024 · 736ea10 · 736ea10
1 parent ee224d8
commit 736ea10
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/packages/indexer-agent/src/agent.ts b/packages/indexer-agent/src/agent.ts
@@ -990,7 +990,7 @@ export class Agent {
 
     // Stop indexing deployments that are no longer worth indexing
     await queue.addAll(
-      remove.map(deployment => async () => this.graphNode.remove(deployment)),
+      pause.map(deployment => async () => this.graphNode.pause(deployment)),
     )
 
     await queue.onIdle()

diff --git a/packages/indexer-common/src/graph-node.ts b/packages/indexer-common/src/graph-node.ts
@@ -331,19 +331,18 @@ export class GraphNode {
     }
   }
 
-  async remove(deployment: SubgraphDeploymentID): Promise<void> {
+  async pause(deployment: SubgraphDeploymentID): Promise<void> {
     try {
-      this.logger.info(`Remove subgraph deployment`, {
+      this.logger.info(`Pause subgraph deployment`, {
         deployment: deployment.display,
       })
-      const response = await this.admin.request('subgraph_reassign', {
-        node_id: 'removed',
-        ipfs_hash: deployment.ipfsHash,
+      const response = await this.admin.request('subgraph_pause', {
+        deployment: deployment.ipfsHash,
       })
       if (response.error) {
         throw response.error
       }
-      this.logger.info(`Successfully removed subgraph deployment`, {
+      this.logger.info(`Successfully paused subgraph deployment`, {
         deployment: deployment.display,
       })
     } catch (error) {