diff --git a/sinks/sink-mongo/tests/test_sink.rs b/sinks/sink-mongo/tests/test_sink.rs index 299b27da..a03c207e 100644 --- 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 index 73c8ecd0..858150fc 100644 --- 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");