A base class for all processings.

Public members¶

DEFAULT_TANGO_TIMEOUT = 1200

Processing(uuid, proc_urls, topology, timeout=1200)

Construct a Processing object.

property uuid

Return the UUID of the processing

property input_frame_info

Return the dtype and shape of the input frame for each receivers

property processed_frame_info

Return the dtype and shape of the processed frame for each receivers

property progress_counters : list[ProgressCounter]

Get the list of aggregated progress counters

ping()

Ping all the devices of the system.

property is_finished

A list of is_finished for each devices.

register_on_finished(cbk)

Register a callback function to be notified on pipeline finish

property last_error

A list of last_error for each devices.

register_on_error(cbk)

Register a callback function to be notified on pipeline error

__repr__()

Return repr(self).

tango_db = None

__sizeof__()

Size of object in memory, in bytes.