◆ on_registration()
def pipeline-python.fiftyone_pipeline_cloudrequestengine.fiftyone_pipeline_cloudrequestengine.cloudengine.CloudEngine.on_registration | ( | self, | |
pipeline | |||
) |
Callback called when an engine is added to a pipeline In this case sets up the properties list for the element from data in the CloudRequestEngine.
@type pipeline: Pipeline
- Parameters
-
- pipeline -
◆ pipeline_element_not_found()
def pipeline-python.fiftyone_pipeline_cloudrequestengine.fiftyone_pipeline_cloudrequestengine.cloudengine.CloudEngine.pipeline_element_not_found ( self, element, flowdata ) Custom 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
◆ process_internal()
def pipeline-python.fiftyone_pipeline_cloudrequestengine.fiftyone_pipeline_cloudrequestengine.cloudengine.CloudEngine.process_internal ( self, flowdata ) Process function of a cloud engine.
This organises and parses data returned from the Cloud Request Engine and adds it to the FlowData
@type flowdata: FlowData
- Parameters
-
- flowdata - FlowData to process