jkuhl/corrlib
1
0
Fork 0
Code Issues 11 Pull requests Releases Packages Activity Actions

HOTFIX: strings for pyerrors 3
All checks were successful
Mypy / mypy (push) Successful in 1m13s
Details
Pytest / pytest (3.12) (push) Successful in 1m15s
Details
Pytest / pytest (3.13) (push) Successful in 1m16s
Details
Pytest / pytest (3.14) (push) Successful in 1m15s
Details
Ruff / ruff (push) Successful in 1m0s
Details

Browse source
This commit is contained in:
Justus Kuhlmann 2026-03-27 11:56:40 +01:00
commit f98521b5a1
Signed by: jkuhl
GPG key ID: 00ED992DD79B85A6
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
corrlib/meas_io.py
View file

@ -59,7 +59,7 @@ def write_measurement(path: Path, ensemble: str, measurement: dict[str, dict[str
if file not in files_to_save: if file not in files_to_save:
unlock(path, file_in_archive) unlock(path, file_in_archive)
files_to_save.append(file_in_archive) files_to_save.append(file_in_archive)
known_meas = pj.load_json_dict(file, verbose=False) known_meas = pj.load_json_dict(str(file), verbose=False)
if code == "sfcf": if code == "sfcf":
if parameter_file is not None: if parameter_file is not None:
parameters = sfcf.read_param(path, uuid, parameter_file) parameters = sfcf.read_param(path, uuid, parameter_file)
@ -113,7 +113,7 @@ def write_measurement(path: Path, ensemble: str, measurement: dict[str, dict[str
c.execute("INSERT INTO backlogs (name, ensemble, code, path, project, parameters, parameter_file, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, datetime('now'), datetime('now'))", c.execute("INSERT INTO backlogs (name, ensemble, code, path, project, parameters, parameter_file, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, datetime('now'), datetime('now'))",
(corr, ensemble, code, meas_path, uuid, pars[subkey], parameter_file)) (corr, ensemble, code, meas_path, uuid, pars[subkey], parameter_file))
conn.commit() conn.commit()
pj.dump_dict_to_json(known_meas, file) pj.dump_dict_to_json(known_meas, str(file))
conn.close() conn.close()
save(path, message="Add measurements to database", files=files_to_save) save(path, message="Add measurements to database", files=files_to_save)
return return
@ -269,11 +269,11 @@ def drop_record(path: Path, meas_path: str) -> None:
raise ValueError("This measurement does not exist as an entry!") raise ValueError("This measurement does not exist as an entry!")
conn.commit() conn.commit()
known_meas = pj.load_json_dict(file) known_meas = pj.load_json_dict(str(file))
if sub_key in known_meas: if sub_key in known_meas:
del known_meas[sub_key] del known_meas[sub_key]
unlock(path, Path(file_in_archive)) unlock(path, Path(file_in_archive))
pj.dump_dict_to_json(known_meas, file) pj.dump_dict_to_json(known_meas, str(file))
save(path, message="Drop measurements to database", files=[db, file]) save(path, message="Drop measurements to database", files=[db, file])
return return
else: else: