sf-daq/sf_daq_broker
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_broker.git synced 2026-05-21 15:10:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

consistent names

Browse Source
This commit is contained in:
NichtJens
2026-02-27 16:44:02 +01:00
parent 3e8e9c371d
commit 8f6069f8b9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf_daq_broker/writer/detector_writer.py
+3 -3
View File
@@ -34,7 +34,7 @@ PEDESTAL_SPECIFIC = {
PEDESTAL_DIRECTORY="/sf/jungfrau/data/pedestal"
TMPDIR = "/gpfs/photonics/swissfel/daqtmp"
TMP_DIRECTORY = "/gpfs/photonics/swissfel/daqtmp"
TMP_SPACE_THRESH = 1e12 # 1TB
@@ -66,7 +66,7 @@ def detector_retrieve(request, output_file_detector):
use_tmp = detector_params.get("remove_raw_files", False)
# get free space in SSD tmp storage, if smaller than threshold do not use it
_tmp_space_total, _tmp_space_used, tmp_space_free = shutil.disk_usage(TMPDIR)
_tmp_space_total, _tmp_space_used, tmp_space_free = shutil.disk_usage(TMP_DIRECTORY)
if tmp_space_free < TMP_SPACE_THRESH:
use_tmp = False
@@ -88,7 +88,7 @@ def detector_retrieve(request, output_file_detector):
if use_tmp:
# flatten folder structure so that there are no empty folders after removal
flat_raw_file_name = raw_file_name.replace("/", "_")
raw_file_name = f"{TMPDIR}/{flat_raw_file_name}"
raw_file_name = f"{TMP_DIRECTORY}/{flat_raw_file_name}"
raw_dir = os.path.dirname(raw_file_name)
os.makedirs(raw_dir, exist_ok=True)
else: