Skip to content
Snippets Groups Projects
Commit f00b43cd authored by Gilles Berruyer's avatar Gilles Berruyer Committed by Wout De Nolf
Browse files

saving workflows could run concurrently

parent 8ddbfcc7
No related branches found
No related tags found
1 merge request!181subscan splitting with known subscan size
Pipeline #225143 passed
......@@ -59,7 +59,12 @@ def split_bliss_scan(
for subscan_number, subscan_slice in enumerate(subscan_slices, 1):
out_url = _save_subscan(
nxentry_in, scan_number, subscan_number, out_filename, subscan_slice
nxentry_in,
scan_number,
subscan_number,
out_filename,
subscan_slice,
**retry_args,
)
out_urls.append(out_url)
return out_urls
......@@ -80,12 +85,15 @@ def _save_subscan(
subscan_number: int,
out_filename: str,
subscan_slice: slice,
**retry_args,
) -> str:
entry_name = f"{scan_number}.{subscan_number}"
out_url = f"silx://{out_filename}::/{entry_name}"
os.makedirs(os.path.dirname(out_filename), exist_ok=True)
with h5py.File(out_filename, mode="a", track_order=True) as nxroot_out:
with h5py_utils.open_item(
out_filename, "/", mode="a", track_order=True, **retry_args
) as nxroot_out:
if entry_name in nxroot_out:
_logger.warning("%s::/%s already exists", out_filename, entry_name)
return out_url
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment