ewokstomo.tasks.online.reconstruct_slice.OnlineReconstructSlice#

class ewokstomo.tasks.online.reconstruct_slice.OnlineReconstructSlice(inputs=None, varinfo=None, node_id=None, node_attrs=None, execinfo=None, profile_directory=None)[source]#

Bases: Task

(ESRF-only) Perform real-time tomography reconstruction on streaming data.

This task connects to a live scan stream and performs incremental reconstruction by processing projections in batches. It includes flat field correction, phase retrieval, and FBP reconstruction.

The reconstruction is performed on a single slice (middle by default) to minimize computational cost while providing real-time feedback.

Parameters:

inputs (Optional[Mapping])
varinfo (Optional[dict])
node_id (Union[str, int, tuple, None])
node_attrs (Optional[dict])
execinfo (Optional[dict])
profile_directory (Optional[dict])

STREAM_TIMEOUT = 5#

WAITING_INTERVAL = 1#

run()[source]#: Execute the online reconstruction pipeline.

save_reconstructed_slice(output_path, reconstructed_slice)[source]#

Save the reconstructed slice to an HDF5 file.

Parameters#

output_pathstr: Path to save the reconstructed slice
reconstructed_slicenp.ndarray: The reconstructed slice data

type output_path:: str
param output_path:
type reconstructed_slice:: ndarray
param reconstructed_slice: