diff --git a/src/sinks/aws_kinesis_firehose/tests.rs b/src/sinks/aws_kinesis_firehose/tests.rs
index 894fd9381a259..2fe3ce23e6fb5 100644
--- a/src/sinks/aws_kinesis_firehose/tests.rs
+++ b/src/sinks/aws_kinesis_firehose/tests.rs
@@ -1,8 +1,8 @@
 #![cfg(test)]
 
 use super::*;
+use crate::aws::RegionOrEndpoint;
 use crate::config::{SinkConfig, SinkContext};
-use crate::rusoto::RegionOrEndpoint;
 use crate::sinks::aws_kinesis_firehose::config::{
     BuildError, MAX_PAYLOAD_EVENTS, MAX_PAYLOAD_SIZE,
 };
@@ -19,7 +19,7 @@ fn generate_config() {
 async fn check_batch_size() {
     let config = KinesisFirehoseSinkConfig {
         stream_name: String::from("test"),
-        region: RegionOrEndpoint::with_endpoint("http://localhost:4566".into()),
+        region: RegionOrEndpoint::with_endpoint("http://localhost:4566"),
         encoding: EncodingConfig::from(StandardEncodings::Json),
         compression: Compression::None,
         batch: BatchConfig {
@@ -44,7 +44,7 @@ async fn check_batch_size() {
 async fn check_batch_events() {
     let config = KinesisFirehoseSinkConfig {
         stream_name: String::from("test"),
-        region: RegionOrEndpoint::with_endpoint("http://localhost:4566".into()),
+        region: RegionOrEndpoint::with_endpoint("http://localhost:4566"),
         encoding: EncodingConfig::from(StandardEncodings::Json),
         compression: Compression::None,
         batch: BatchConfig {