Skip to content

Commit

Permalink
fix check
Browse files Browse the repository at this point in the history
  • Loading branch information
xzhseh committed Apr 16, 2024
1 parent a2657da commit ad09874
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/connector/src/sink/snowflake_connector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ impl SnowflakeHttpClient {
"KEYPAIR_JWT",
)
.body(generate_s3_file_name(
self.s3_path.as_ref().map(|s| s.as_str()),
self.s3_path.as_deref(),
file_suffix,
));

Expand Down Expand Up @@ -210,10 +210,10 @@ impl SnowflakeS3Client {
&aws_secret_access_key,
&aws_region,
)
.map_err(|e| {
.map_err(|err| {
SinkError::Snowflake(format!(
"failed to create opendal s3 engine, error: {}",
e.to_string()
err
))
})?;

Expand All @@ -225,6 +225,6 @@ impl SnowflakeS3Client {
}

pub fn s3_path(&self) -> Option<&str> {
self.s3_path.as_ref().map(|s| s.as_str())
self.s3_path.as_deref()
}
}

0 comments on commit ad09874

Please sign in to comment.