Skip to content

Commit a829b9e

Browse files
author
Devdutt Shenoi
committed
fix: create_dir_all
1 parent e65d4e6 commit a829b9e

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/parseable/streams.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -122,6 +122,7 @@ impl Stream {
122122
parsed_timestamp,
123123
custom_partition_values,
124124
);
125+
std::fs::create_dir_all(&self.data_path)?;
125126

126127
let mut writer = DiskWriter::new(path_prefix, &record.schema())?;
127128
writer.write(record)?;

0 commit comments

Comments
 (0)