Updated prefix

2026-03-13 01:16:35 +01:00
1 changed files with 1 additions and 1 deletions
--- a/lib/storage.ts
+++ b/lib/storage.ts
@@ -185,7 +185,7 @@ function partitionPathFromSegmentId(id: string): string {
 }

 function buildPartitionedFilePath(prefix: string, id: string): string {
-  return path.join(DATA_DIR, partitionPathFromSegmentId(id), `${prefix}-${id}.parquet`);
+  return path.join(DATA_DIR, prefix, partitionPathFromSegmentId(id), `${prefix}-${id}.parquet`);
 }

 function buildVehicleFile(id: string): string {