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)

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)

Execute all “one shot” functions.

log_exception(self, exception, work_name, key)

Log an exception in a file.

Classes

ExecutorSequential(topology, path_dir_result)

Execute a topology sequentially