valve set block_ptr on each block processed

vutran1710 · vutran1710 · commit b1ae609b3939 · 2023-12-04T13:18:58.000+07:00
diff --git a/src/main.rs b/src/main.rs
@@ -108,12 +108,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
                 subgraph.create_sources(&manifest, &db, &rpc).await?;
                 subgraph.process(block).await?;
+                valve.set_finished(block_ptr.number);
             }
 
             if let Some(block_ptr) = last_block {
                 db.commit_data(block_ptr.clone()).await?;
                 db.flush_cache().await?;
-                valve.set_finished(block_ptr.number);
             }
 
             info!(

Original file line number	Diff line number	Diff line change
`@@ -108,12 +108,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {`
`108`	`108`
`109`	`109`	`subgraph.create_sources(&manifest, &db, &rpc).await?;`
`110`	`110`	`subgraph.process(block).await?;`
	`111`	`+ valve.set_finished(block_ptr.number);`
`111`	`112`	`}`
`112`	`113`
`113`	`114`	`if let Some(block_ptr) = last_block {`
`114`	`115`	`db.commit_data(block_ptr.clone()).await?;`
`115`	`116`	`db.flush_cache().await?;`
`116`		`- valve.set_finished(block_ptr.number);`
`117`	`117`	`}`
`118`	`118`
`119`	`119`	`info!(`