spacr._mask_workers

Process isolation and cooperative stop for assigned mask batches.

Nested helpers

_generate_masks_in_parallel.report(state)

Keep the latest snapshot for the summary and print it for the GUI.

spacr/_mask_workers.py:1039

_mask_worker.completed(path)

Publish completion only after the pipeline’s save boundary.

spacr/_mask_workers.py:551

_run_checkpointed_mask_workers.progress(state)

Persist each newly completed archive before publishing aggregate progress.

spacr/_mask_workers.py:351

_run_mask_workers.consume(message)

Validate archive ownership before accepting a worker’s event.

spacr/_mask_workers.py:628

_run_mask_workers.publish()

Do not let consumers mutate scheduler bookkeeping.

spacr/_mask_workers.py:622

_run_mask_workers.run_group(group)

Join every member of one primary or serial final worker group.

spacr/_mask_workers.py:675

_worker_figures.publish(fig, path=None)

Freeze the figure now, before the child can change or close it.

spacr/_mask_workers.py:439

_worker_figures.show(*args, **kwargs)

Publish each shown figure once and release child pyplot ownership.

spacr/_mask_workers.py:459