◆ __init__()
| def pipeline-python.fiftyone_pipeline_core.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 pipeline-python.fiftyone_pipeline_core.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 pipeline-python.fiftyone_pipeline_core.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 pipeline-python.fiftyone_pipeline_core.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 pipeline-python.fiftyone_pipeline_core.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 pipeline-python.fiftyone_pipeline_core.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