\r\n

51Degrees Pipeline Python  4.4

51Degrees Pipeline for Python

fiftyone_pipeline_core.pipeline.Pipeline Class Reference

Detailed Description

Pipeline holding a list of FlowElements for processing, can create FlowData that will be passed through these, collecting ElementData Should be constructed through the PipelineBuilder class.

Public Member Functions

def  __init__ (self, flow_elements, logger=Logger(), suppress_process_exceptions=False, data_file_update_service=None)
Pipeline constructor. More...
def  create_flowdata (self)
Create a FlowData based on what's in the pipeline. More...
def  log (self, level, message)
Log a message using the Logger.log of the pipeline's Logger. More...
def  get_element (self, key)
Get a flowElement by its name. More...
def  element_not_found (self, element, flowdata)
Trigger error when an element cannot be found in the pipeline. More...
def  get_properties (self)
Get all properties of all flowElements in the pipeline. More...

Public Attributes

 logger
 flow_elements_list
 flow_elements_display_list
 suppress_process_exceptions
 data_file_update_service

Constructor & Destructor Documentation

◆ __init__()

def fiftyone_pipeline_core.pipeline.Pipeline.__init__ (   self,
  flow_elements,
  logger = Logger(),
  suppress_process_exceptions = False,
  data_file_update_service = None  
)

Pipeline constructor.

@type flow_elements: list[FlowElement]

Parameters
flow_elements - A list of flowElements

@type logger: Logger

Parameters
logger - A logger to attach to the pipeline

@type suppress_process_exceptions: boolean

Parameters
suppress_process_exceptions - If true then pipeline will suppress exceptions added to FlowData.errors otherwise will throw the exception occurred during the processing of first element.

@rtype: Pipeline

Returns
: Returns a Pipeline

Member Function Documentation

◆ create_flowdata()

def fiftyone_pipeline_core.pipeline.Pipeline.create_flowdata (   self )

Create a FlowData based on what's in the pipeline.

@rtype: FlowData

Returns
: Return a FlowData

◆ element_not_found()

def fiftyone_pipeline_core.pipeline.Pipeline.element_not_found (   self,
  element,
  flowdata  
)

Trigger error when an element cannot be found in the pipeline.

@type element: string

Parameters
element - name of flowelement @type flowdata: flowdata
element - flowdata being processsed @rtype: Exception
Returns
: Returns exception

◆ get_element()

def fiftyone_pipeline_core.pipeline.Pipeline.get_element (   self,
  key  
)

Get a flowElement by its name.

@type key: string

Parameters
key - name of flowElement

@rtype: FlowElement

Returns
: Returns the FlowElement indicated

◆ get_properties()

def fiftyone_pipeline_core.pipeline.Pipeline.get_properties (   self )

Get all properties of all flowElements in the pipeline.

@rtype: dict of {string : DataPropertyDictionary}

Returns
: Returns dictionary of all properties in a pipeline keyed by each flowElement's FlowElement.datakey.

◆ log()

def fiftyone_pipeline_core.pipeline.Pipeline.log (   self,
  level,
  message  
)

Log a message using the Logger.log of the pipeline's Logger.

@type level: string

Parameters
level - level of log message

@type message: string

Parameters
message - Returns content of log message

Member Data Documentation

◆ data_file_update_service

fiftyone_pipeline_core.pipeline.Pipeline.data_file_update_service

◆ flow_elements

fiftyone_pipeline_core.pipeline.Pipeline.flow_elements

◆ flow_elements_display_list

fiftyone_pipeline_core.pipeline.Pipeline.flow_elements_display_list

◆ flow_elements_list

fiftyone_pipeline_core.pipeline.Pipeline.flow_elements_list

◆ logger

fiftyone_pipeline_core.pipeline.Pipeline.logger

◆ suppress_process_exceptions

fiftyone_pipeline_core.pipeline.Pipeline.suppress_process_exceptions
On This Page