chore(sinks): migrated assert sink

txpipe · Jul 18, 2023 · a86f3ec · a86f3ec
1 parent aff854b
commit a86f3ec
Show file tree

Hide file tree

Showing 6 changed files with 1 addition and 224 deletions.
diff --git a/src/sinks/_pending/assert/checks.rs b/src/sinks/_pending/assert/checks.rs
diff --git a/src/sinks/_pending/assert/mod.rs b/src/sinks/_pending/assert/mod.rs
diff --git a/src/sinks/_pending/assert/prelude.rs b/src/sinks/_pending/assert/prelude.rs
diff --git a/src/sinks/_pending/assert/run.rs b/src/sinks/_pending/assert/run.rs
diff --git a/src/sinks/_pending/assert/setup.rs b/src/sinks/_pending/assert/setup.rs
diff --git a/src/sinks/assert/mod.rs b/src/sinks/assert/mod.rs
@@ -103,11 +103,6 @@ impl gasket::framework::Worker<Stage> for Worker {
         run_check!(&stage.config, &self.state, tx_records_matches_block_count);
         run_check!(&stage.config, &self.state, tx_has_input_and_output);
 
-        if let Some(event) = &self.state.current_event {
-            // notify pipeline about the progress
-            // utils.track_sink_progress(event);
-        }
-
         stage.ops_count.inc(1);
         stage.latest_block.set(point.slot_or_default() as i64);
         stage.cursor.add_breadcrumb(point.clone());
@@ -117,7 +112,7 @@ impl gasket::framework::Worker<Stage> for Worker {
 }
 
 #[derive(Stage)]
-#[stage(name = "sink-aws-sqs", unit = "ChainEvent", worker = "Worker")]
+#[stage(name = "sink-assert", unit = "ChainEvent", worker = "Worker")]
 pub struct Stage {
     config: Config,
     cursor: Cursor,