Skip to content

Commit

Permalink
minor changes
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Aug 19, 2023
1 parent 682cd97 commit 16bb18f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions nexus/analyzer/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ struct CatalogArgs {
}

fn stage_check(stage: String, peer_type: DbType) -> Result<(), anyhow::Error> {
if stage.len() > 0 && !stage.starts_with("s3://") && peer_type == DbType::Snowflake {
if !stage.is_empty() && !stage.starts_with("s3://") && peer_type == DbType::Snowflake {
return Err(anyhow::anyhow!(
"Staging path for Snowflake must either be an S3 URL or an empty string for staging inside PeerDB."
));
Expand Down Expand Up @@ -81,7 +81,7 @@ fn mirror_input_checks(flow_job: &FlowJob) -> anyhow::Result<bool> {
"cdc_staging_path", path_missing_err
)));
} else if let Some(cdc_stage) = flow_job.cdc_staging_path.clone() {
let _ = stage_check(cdc_stage, destination_peer_type)?;
stage_check(cdc_stage, destination_peer_type)?;
}
}

Expand Down

0 comments on commit 16bb18f

Please sign in to comment.