tomwer.core.process.cluster.supervisor.FutureSupervisorTask

class tomwer.core.process.cluster.supervisor.FutureSupervisorTask(inputs=None, varinfo=None, node_id=None, node_attrs=None, execinfo=None, profile_directory=None)

Task used to wait for a ‘FutureTomwerObject’ and convert it to original instance of:

• TomwerScanBase (data): if the FutureTomwerObject is based on a scan instance

• TomwerVolumeBase (volume): if the FutureTomwerObject is based on a volume instance

• tuple of IcatReconstructedVolumeDataset (data_portal_processed_datasets): if the FutureTomwerObject is based on a volume instance

run()

To be implemented by the derived classes