mirror of
https://github.com/m-labs/artiq.git
synced 2024-12-28 20:53:35 +08:00
worker, hdf5: move datasets to subgroup
This commit is contained in:
parent
1ff01a43ff
commit
4e7b004a4e
@ -20,6 +20,12 @@ unreleased [2.x]
|
||||
just "-m qcX" or "-m clock" (#290).
|
||||
|
||||
|
||||
unreleased [1.0rc3]
|
||||
-------------------
|
||||
|
||||
* The HDF5 format has changed. The datasets are located in the subgroup ``datasets``.
|
||||
|
||||
|
||||
1.0rc2
|
||||
------
|
||||
|
||||
|
@ -250,4 +250,5 @@ class DatasetManager:
|
||||
return self.ddb.get(key)
|
||||
|
||||
def write_hdf5(self, f):
|
||||
result_dict_to_hdf5(f, self.local)
|
||||
g = f.create_group("datasets")
|
||||
result_dict_to_hdf5(g, self.local)
|
||||
|
@ -218,14 +218,11 @@ def main():
|
||||
exp_inst.analyze()
|
||||
put_object({"action": "completed"})
|
||||
elif action == "write_results":
|
||||
f = get_hdf5_output(start_time, rid, exp.__name__)
|
||||
try:
|
||||
with get_hdf5_output(start_time, rid, exp.__name__) as f:
|
||||
dataset_mgr.write_hdf5(f)
|
||||
string_to_hdf5(f, "artiq_version", artiq_version)
|
||||
string_to_hdf5(f, "version", artiq_version)
|
||||
if "repo_rev" in expid:
|
||||
string_to_hdf5(f, "repo_rev", expid["repo_rev"])
|
||||
finally:
|
||||
f.close()
|
||||
put_object({"action": "completed"})
|
||||
elif action == "examine":
|
||||
examine(ExamineDeviceMgr, ParentDatasetDB, obj["file"])
|
||||
|
Loading…
Reference in New Issue
Block a user