Skip to content

Commit

Permalink
Print input path with zarrs_{ncva2zarr,ome}
Browse files Browse the repository at this point in the history
  • Loading branch information
LDeakin committed Apr 27, 2024
1 parent 1b797d4 commit 1f6964d
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 3 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- `zarrs_ome` also supports an `overwrite` option
- `zarrs_{ncvar,binary}2zarr` output size change in human readable bytes
- Change `zarrs_{filter,ome}` to multi progress bars
- Print input path with `zarrs_{ncva2zarr,ome}`

### Removed
- Remove `--hide-progress` from `zarrs_filter`
Expand Down
8 changes: 5 additions & 3 deletions src/bin/zarrs_ncvar2zarr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ struct Cli {
memory_test: bool,

/// The path to a netCDF file or a directory of netcdf files.
path: PathBuf,
input: PathBuf,

/// The name of the netCDF variable.
variable: String,
Expand Down Expand Up @@ -228,9 +228,12 @@ fn main() {
if let Some(shard_shape) = &cli.encoding.shard_shape {
assert_eq!(cli.encoding.chunk_shape.len(), shard_shape.len());
}
println!("Input {:?}", cli.input);

let start = std::time::Instant::now();

// Sort the files
let nc_paths = get_netcdf_paths(&cli.path).expect("cannot retrieve netCDF filenames");
let nc_paths = get_netcdf_paths(&cli.input).expect("cannot retrieve netCDF filenames");
// println!("{nc_paths:?}");

// Inspect the variable for each netCDF file, and get the
Expand Down Expand Up @@ -314,7 +317,6 @@ fn main() {
array.store_metadata().unwrap();

// Read stdin to the array and write chunks/shards
let start = std::time::Instant::now();
let bytes_read: usize = ncfiles_to_array(
&nc_paths,
&offsets,
Expand Down
2 changes: 2 additions & 0 deletions src/bin/zarrs_ome.rs
Original file line number Diff line number Diff line change
Expand Up @@ -243,6 +243,8 @@ fn run() -> Result<(), Box<dyn Error>> {
// Parse command line arguments
let cli = Cli::parse();

println!("Input {:?}", cli.input);

let start = std::time::Instant::now();

let store_in = FilesystemStore::new(&cli.input)?;
Expand Down

0 comments on commit 1f6964d

Please sign in to comment.