Skip to content

Commit 56ac3cf

Browse files
committed
include table name in uri so we can have different tables in future
1 parent 060267d commit 56ac3cf

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/database.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,8 @@ impl Database {
5454

5555
// Generate a unique prefix for this run's data
5656
let prefix = env::var("TIMEFUSION_TABLE_PREFIX").unwrap_or_else(|_| "timefusion".to_string());
57-
let storage_uri = format!("s3://{}/{}/?endpoint={}", bucket, prefix, aws_endpoint);
57+
let table_name = "otel_logs_and_spans";
58+
let storage_uri = format!("s3://{}/{}/{}/?endpoint={}", bucket, prefix, table_name, aws_endpoint);
5859
info!("Storage URI configured: {}", storage_uri);
5960

6061
let aws_url = Url::parse(&aws_endpoint).expect("AWS endpoint must be a valid URL");

0 commit comments

Comments
 (0)