PR fixes.

src/identity/processor.rs

@@ -435,17 +435,17 @@ impl OnChainIdentityProcessor {
                 // how required mined_at field is set, We set proper state only if not set
                 // previously.
                 let root_state = tx.get_root_state(&post_root).await?;
-                match root_state {
-                    Some(root_state) if root_state.status == ProcessedStatus::Processed => {}
-                    Some(root_state) if root_state.status == ProcessedStatus::Mined => {}
-                    _ => {
-                        tx.mark_root_as_processed(&post_root).await?;
+                if let Some(root_state) = root_state {
+                    if root_state.status == ProcessedStatus::Processed || root_state.status == ProcessedStatus::Mined {
+                        return Ok::<(), anyhow::Error>(());
                     }
                 }
 
+                tx.mark_root_as_processed(&post_root).await?;
+
                 Ok::<(), anyhow::Error>(())
             })
-            .await?;
+                .await?;
 
             info!(?pre_root, ?post_root, ?kind, "Batch mined");
 

src/task_monitor/tasks/modify_tree.rs

@@ -34,7 +34,7 @@ pub async fn modify_tree(
     let mut timer = time::interval(Duration::from_secs(5));
 
     loop {
-        // We wait either for a timer tick or a full batch
+        // We wait either for a timer tick or a event that tree was synchronized
         select! {
             _ = timer.tick() => {
                 info!("Modify tree task woken due to timeout");