fluidimage.executors.exec_sequential

Execute a topology sequentially (fluidimage.executors.exec_async_sequential)

class fluidimage.executors.exec_sequential.ExecutorBase(topology, path_dir_result, nb_max_workers=None, nb_items_queue_max=None, logging_level='info', sleep_time=None, stop_if_error=False)[source]

Bases: object

Base class for executors.

Parameters
topologyfluidimage.topology.base.TopologyBase

A computational topology.

path_dir_resultstr or pathlib.Path

The path of the directory where the results have to be saved.

nb_max_workersint, optional (None)
nb_items_queue_maxint, optional (None),
logging_levelstr, optional {“info”},
sleep_timenumber, optional {None},
stop_if_errorbool, optional {False}
exec_one_shot_works(self)[source]

Execute all “one shot” functions.

log_exception(self, exception, work_name, key)[source]

Log an exception in a file.

Classes

ExecutorSequential(topology, path_dir_result)

Execute a topology sequentially