Skip to content

Commit 076b030

Browse files
peaseelukekim
authored andcommitted
fix: Use unique ETL target prefixes (#53)
* fix: Use unique ETL target prefixes * fix
1 parent 1574b6f commit 076b030

1 file changed

Lines changed: 9 additions & 10 deletions

File tree

src/main.rs

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -84,18 +84,17 @@ async fn main() -> anyhow::Result<()> {
8484
executor_instance_type: cli.common.executor_instance_type.clone(),
8585
};
8686

87+
let run_suffix = Uuid::new_v4().to_string();
88+
let target_prefix = if cli.common.etl_target_base_prefix.is_empty() {
89+
run_suffix.clone()
90+
} else {
91+
format!("{}/{run_suffix}", cli.common.etl_target_base_prefix)
92+
};
93+
tracing::info!(target_prefix = %target_prefix, "Generated unique ETL target prefix");
94+
8795
let target_config = TargetConfig {
8896
bucket: cli.common.etl_bucket.clone(),
89-
prefix: {
90-
let run_suffix = Uuid::new_v4().to_string();
91-
let target_prefix = if cli.common.etl_target_base_prefix.is_empty() {
92-
run_suffix.clone()
93-
} else {
94-
format!("{}/{run_suffix}", cli.common.etl_target_base_prefix)
95-
};
96-
tracing::info!(target_prefix = %target_prefix, "Generated unique ETL target prefix");
97-
target_prefix
98-
},
97+
prefix: target_prefix,
9998
region: cli.common.etl_region.clone(),
10099
endpoint: cli.common.etl_endpoint.clone(),
101100
table_format: cli.common.table_format.clone(),

0 commit comments

Comments
 (0)