Skip to content
Merged
Show file tree
Hide file tree
Changes from 30 commits
Commits
Show all changes
42 commits
Select commit Hold shift + click to select a range
b0892f2
rework some preproc functions, test jobdb implementation
Aug 22, 2025
520cb90
some updates
Aug 22, 2025
1051c87
fix typo, only remove failed jobs
Aug 22, 2025
59bf9a4
push for to allow merge
Nov 19, 2025
675e0db
Merge branch 'master' into 20250822_preproc_update
mmccrackan Nov 19, 2025
f4a3f54
merge fixes
Nov 19, 2025
20a8537
some fixes/cleanup
Nov 20, 2025
5a09ff4
rework outputs, add jobdb tag
Nov 21, 2025
7370dd9
fix some errors
Nov 21, 2025
7ff3d39
address some comments, rework jobdb, cleanup docstring format
Dec 2, 2025
1ada5df
match dets dict for jobdb, try updating mapmaker
Dec 2, 2025
bc6414f
fix init db jobdb check
Dec 2, 2025
e139212
fix for race condition
Dec 2, 2025
e0e45ad
add ignore config check option, tqdm to file, docstring fixes
Dec 4, 2025
355dccd
fix typos
Dec 4, 2025
9033846
rework group handing, fix error output
Dec 4, 2025
111e78e
handle None in errlog
Dec 4, 2025
b4bbaa6
track failed vs done, fix subdir
Dec 5, 2025
fe4b2ed
Merge branch 'master' into 20250822_preproc_update
mmccrackan Dec 5, 2025
10670ed
fix db creation problem
Dec 5, 2025
6487f38
feat: add functions to add multiple jobs at once
skhrg Dec 6, 2025
4ecd0f2
fix save_proc_aman
Dec 8, 2025
559919d
many updates
Dec 18, 2025
7d33589
fix for jobdb
Dec 18, 2025
3eeb165
docstring fix
Dec 18, 2025
843f713
fix for docstring
Dec 18, 2025
088478c
add compression
Dec 19, 2025
b52c448
fix quanta for float32
Dec 19, 2025
13a1e62
update site pipeline utils imports
Dec 23, 2025
78c2d59
Merge branch 'master' into 20250822_preproc_update
mmccrackan Dec 23, 2025
f295a1b
feat: recombine make_job and create_job and speed up commit_jobs
skhrg Dec 23, 2025
dc6f345
disable existence check, handle cleaned up jobs
Dec 23, 2025
84a418d
fix state
Jan 2, 2026
9aff589
update jobdb
Jan 2, 2026
1df5175
minor docstring fix
mhasself Jan 9, 2026
2961297
Merge remote-tracking branch 'origin' into 20250822_preproc_update
Jan 9, 2026
5d6de5d
update jobdb
Jan 9, 2026
6f0265b
fix mapmaker error handling
Jan 9, 2026
784258c
make preproc db in mapmaker
Jan 12, 2026
f19b0dd
add skip_missing for preproc_or_load_group
Jan 13, 2026
1a71891
change compress arg, rename progress bar file
Jan 14, 2026
b3d6d72
prevent lingering init files
Jan 14, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion docs/preprocess.rst
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,12 @@ These functions support and are used within the driver processing scripts
above and are useful for saving, loading, and verifying preprocessing archives
and databases.

.. autoclass:: sotodlib.preprocess.preprocess_util.PreprocessErrors
:members:
:undoc-members:
:show-inheritance:

.. autofunction:: sotodlib.preprocess.preprocess_util.filter_preproc_runlist_by_jobdb

.. autofunction:: sotodlib.preprocess.preprocess_util.init_logger

Expand All @@ -87,7 +93,7 @@ and databases.

.. autofunction:: sotodlib.preprocess.preprocess_util.find_db

.. autofunction:: sotodlib.preprocess.preprocess_util.save_group
.. autofunction:: sotodlib.preprocess.preprocess_util.get_preproc_group_out_dict

.. autofunction:: sotodlib.preprocess.preprocess_util.save_group_and_cleanup

Expand Down
4 changes: 2 additions & 2 deletions sotodlib/mapmaking/demod_mapmaker.py
Original file line number Diff line number Diff line change
Expand Up @@ -604,13 +604,13 @@ def make_demod_map(context, obslist, noise_model, info,
for oi in range(len(obslist)):
obs_id, detset, band = obslist[oi][:3]
name = "%s:%s:%s" % (obs_id, detset, band)
error, output_init, output_proc, obs = preprocess_util.preproc_or_load_group(obs_id,
obs, output_init, output_proc, error = preprocess_util.preproc_or_load_group(obs_id,
configs_init=preproc_init,
configs_proc=preproc_proc,
dets={'wafer_slot':detset, 'wafer.bandpass':band},
logger=L,
overwrite=False)
errors.append(error) ; outputs.append((output_init, output_proc)) ;
errors.append(error[0]) ; outputs.append((output_init, output_proc)) ;
if error not in [None,'load_success']:
L.info('tod %s:%s:%s failed in the preproc database'%(obs_id,detset,band))
continue
Expand Down
Loading