postgres: use Batcher::by_seconds instead of Batcher::by_secs

apibara · Mar 9, 2024 · 147288b · 147288b
1 parent 1f43660
commit 147288b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/sinks/sink-mongo/tests/test_sink.rs b/sinks/sink-mongo/tests/test_sink.rs
@@ -4,7 +4,6 @@ use apibara_core::node::v1alpha2::{Cursor, DataFinality};
 use apibara_sink_common::{batching::Buffer, Context, CursorAction, Sink, ValueExt};
 use apibara_sink_mongo::{MongoSink, SinkMongoError, SinkMongoOptions};
 
-
 use error_stack::{Result, ResultExt};
 use futures_util::TryStreamExt;
 use mongodb::bson::{doc, Bson, Document};

diff --git a/sinks/sink-postgres/src/sink.rs b/sinks/sink-postgres/src/sink.rs
@@ -97,7 +97,7 @@ impl Sink for PostgresSink {
 
         let client = client_from_config(&config).await?;
 
-        let batcher = Batcher::by_secs(config.batch_seconds);
+        let batcher = Batcher::by_seconds(config.batch_seconds);
 
         info!("client connected successfully");