| 249 | } |
| 250 | |
| 251 | async fn load_data( |
| 252 | store: Arc<dyn ObjectStore>, |
| 253 | files_on_disk: &[PathBuf], |
| 254 | ) -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> { |
| 255 | for file in files_on_disk { |
| 256 | let bytes = std::fs::read(file)?; |
| 257 | |
| 258 | let path = object_store::path::Path::from_iter([ |
| 259 | "data", |
| 260 | file.file_name().unwrap().to_str().unwrap(), |
| 261 | ]); |
| 262 | let payload = object_store::PutPayload::from_bytes(bytes.into()); |
| 263 | store |
| 264 | .put_opts(&path, payload, object_store::PutOptions::default()) |
| 265 | .await?; |
| 266 | } |
| 267 | |
| 268 | Ok(()) |
| 269 | } |
| 270 | |
| 271 | async fn generate_data( |
| 272 | data_dir: impl AsRef<Path>, |