Skip to content
Snippets Groups Projects
Commit 692fb9cd authored by Laurent Mercadier's avatar Laurent Mercadier
Browse files

Adds runFolder as attribute

parent 57925d4a
No related branches found
No related tags found
1 merge request!34Attributes
...@@ -328,8 +328,8 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False, ...@@ -328,8 +328,8 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False,
or dictionnaries defining a custom mnemonic such as or dictionnaries defining a custom mnemonic such as
{"extra": {'SCS_CDIFFT_MAG/SUPPLY/CURRENT', 'actual_current.value', None}} {"extra": {'SCS_CDIFFT_MAG/SUPPLY/CURRENT', 'actual_current.value', None}}
runNB: run number as integer runNB: run number as integer
proposalNB: string of the proposal number proposalNB: string or int of the proposal number e.g. 'p002252' or 2252
semesterNB: string of the semester number where the proposal data are saved semesterNB: string or int of the semester number where the proposal data are saved
topic: string of the topic topic: string of the topic
display: boolean, whether to show the run.info or not display: boolean, whether to show the run.info or not
validate: boolean, whether to run karabo-data-validate or not validate: boolean, whether to run karabo-data-validate or not
...@@ -346,6 +346,8 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False, ...@@ -346,6 +346,8 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False,
res: an xarray DataSet with aligned trainIds res: an xarray DataSet with aligned trainIds
""" """
if type(proposalNB)==int:
proposalNB = 'p{:06d}'.format(proposalNB)
runFolder = runpath.format(topic, semesterNB, proposalNB, runNB) runFolder = runpath.format(topic, semesterNB, proposalNB, runNB)
run = RunDirectory(runFolder).select_trains(subset) run = RunDirectory(runFolder).select_trains(subset)
...@@ -401,4 +403,5 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False, ...@@ -401,4 +403,5 @@ def load(fields, runNB, proposalNB, semesterNB, topic='SCS', display=False,
result = dict(zip(keys, aligned_vals)) result = dict(zip(keys, aligned_vals))
result = xr.Dataset(result) result = xr.Dataset(result)
result.attrs['run'] = run result.attrs['run'] = run
result.attrs['runFolder'] = runFolder
return result return result
...@@ -177,7 +177,8 @@ def cleanXGMdata(data, npulses=None, sase3First=True): ...@@ -177,7 +177,8 @@ def cleanXGMdata(data, npulses=None, sase3First=True):
mergeList.append(res) mergeList.append(res)
mergeList.append(data.drop(dropList)) mergeList.append(data.drop(dropList))
subset = xr.merge(mergeList, join='inner') subset = xr.merge(mergeList, join='inner')
subset.attrs['run'] = data.attrs['run'] for k in data.attrs.keys():
subset.attrs[k] = data.attrs[k]
return subset return subset
...@@ -937,7 +938,8 @@ def matchXgmTimPulseId(data, use_apd=True, intstart=None, intstop=None, ...@@ -937,7 +938,8 @@ def matchXgmTimPulseId(data, use_apd=True, intstart=None, intstop=None,
dropList.append('MCP{}apd'.format(mcp)) dropList.append('MCP{}apd'.format(mcp))
mergeList.append(ndata.drop(dropList)) mergeList.append(ndata.drop(dropList))
subset = xr.merge(mergeList, join='inner') subset = xr.merge(mergeList, join='inner')
subset.attrs['run'] = ndata.attrs['run'] for k in ndata.attrs.keys():
subset.attrs[k] = ndata.attrs[k]
return subset return subset
......
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