store: Asyncify rollup::Rollup::insert

Author: lutter

store/postgres/src/deployment_store.rs

@@ -1166,7 +1166,7 @@ impl DeploymentStore {
                     )?;
                     section.end();
 
-                    layout.rollup(conn, last_rollup, &batch.block_times)?;
+                    layout.rollup(conn, last_rollup, &batch.block_times).await?;
 
                     dynds::insert(conn, &site, &batch.data_sources, manifest_idx_and_name).await?;
 

store/postgres/src/relational.rs

@@ -1186,7 +1186,7 @@ impl Layout {
     ///
     /// Changing this would require that we have a complete list of block
     /// numbers and block times which we do not have anywhere in graph-node.
-    pub(crate) fn rollup(
+    pub(crate) async fn rollup(
         &self,
         conn: &mut PgConnection,
         last_rollup: Option<BlockTime>,
@@ -1238,7 +1238,7 @@ impl Layout {
                         break;
                     }
                     Some(bucket) => {
-                        rollup.insert(conn, &bucket, *block)?;
+                        rollup.insert(conn, &bucket, *block).await?;
                     }
                 }
             }

store/postgres/src/relational/rollup.rs

@@ -270,7 +270,7 @@ impl Rollup {
         })
     }
 
-    pub(crate) fn insert(
+    pub(crate) async fn insert(
         &self,
         conn: &mut PgConnection,
         bucket: &Range<BlockTime>,