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:1030

_mask_worker.completed(path)

Publish completion only after the pipeline’s save boundary.

spacr/_mask_workers.py:542

_run_checkpointed_mask_workers.progress(state)

Persist each newly completed archive before publishing aggregate progress.

spacr/_mask_workers.py:342

_run_mask_workers.consume(message)

Validate archive ownership before accepting a worker’s event.

spacr/_mask_workers.py:619

_run_mask_workers.publish()

Do not let consumers mutate scheduler bookkeeping.

spacr/_mask_workers.py:613

_run_mask_workers.run_group(group)

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

spacr/_mask_workers.py:666

_worker_figures.publish(fig, path=None)

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

spacr/_mask_workers.py:430

_worker_figures.show(*args, **kwargs)

Publish each shown figure once and release child pyplot ownership.

spacr/_mask_workers.py:450