graph: use object-store for dips metrics

graphprotocol · Mar 5, 2024 · 795bd4c · 795bd4c
1 parent c8d46f8
commit 795bd4c
Show file tree

Hide file tree

Showing 6 changed files with 233 additions and 60 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/chain/substreams/src/trigger.rs b/chain/substreams/src/trigger.rs
@@ -197,7 +197,7 @@ where
     async fn process_trigger(
         &self,
         logger: &Logger,
-        _: Box<dyn Iterator<Item = &T::Host> + Send + '_>,
+        _: Box<dyn Iterator<Item = &T::Host> + Send + 'life0>,
         block: &Arc<Block>,
         _trigger: &data_source::TriggerData<Chain>,
         mut state: BlockState<Chain>,

diff --git a/core/src/subgraph/runner.rs b/core/src/subgraph/runner.rs
@@ -610,7 +610,7 @@ where
         // Spawns a task to upload gas metrics to GCS, enabled via ENV_VARS.enable_gas_metrics.
         // Logs errors without interrupting block processing.
         if ENV_VARS.enable_gas_metrics {
-            match self.metrics.host.gas_metrics.flush_metrics_to_gcs(
+            match self.metrics.host.gas_metrics.flush_metrics_to_store(
                 &logger,
                 block_ptr,
                 self.inputs.deployment.id,

diff --git a/graph/Cargo.toml b/graph/Cargo.toml
@@ -72,6 +72,7 @@ itertools = "0.12.0"
 web3 = { git = "https://github.com/graphprotocol/rust-web3", branch = "graph-patches-onto-0.18", features = ["arbitrary_precision"] }
 serde_plain = "1.0.2"
 csv = "1.3.0"
+object_store = { version = "0.9.1", features = ["gcp"] }
 cloud-storage = { version = "0.11.1", features = ["global-client"] }
 
 [dev-dependencies]