Detailed Description
Adds ClosingData to each FlowData, and counts its own closes.
Inheritance diagram for tests.test_close.ClosingElement:
Collaboration diagram for tests.test_close.ClosingElement:
Public Member Functions | |
| __init__ (self) | |
| process_internal (self, flowdata) | |
| The method behind FlowElement.Process - it is called by the process() function. | |
| close (self) | |
| Release the resources the element holds. | |
Public Member Functions inherited from fiftyone_pipeline_core.flowelement.FlowElement | |
| __init__ (self) | |
| List of Pipelines the FlowElement has been added to. | |
| process (self, flowdata) | |
| Function for getting the FlowElement's EvidenceKeyFilter Used by the filterEvidence method. | |
| on_registration (self, pipeline) | |
| Function called when an element is added to the pipeline. | |
| get_evidence_key_filter (self) | |
| Filter FlowData evidence using the FlowElement's EvidenceKeyFilter. | |
| filter_evidence (self, flowdata) | |
| Filter FlowData evidence using the FlowElement's EvidenceKeyFilter. | |
| filter_evidence_key (self, key) | |
| Filter FlowData.evidence using the flowElement's EvidenceKeyFilter with the property key of evidence of interest. | |
| get_properties (self) | |
| Get the FlowElement.properties of a FlowElement. | |
Public Attributes | |
| int | closes = 0 |
Public Attributes inherited from fiftyone_pipeline_core.flowelement.FlowElement | |
| list | pipelines = [] |
| dict | properties = {} |
| str | datakey = "" |
| bool | exclude_from_messages = False |
Additional Inherited Members | |
Protected Member Functions inherited from fiftyone_pipeline_core.flowelement.FlowElement | |
| _log (self, level, message) | |
Constructor & Destructor Documentation
◆ __init__()
| tests.test_close.ClosingElement.__init__ | ( | self | ) |
Member Function Documentation
◆ close()
| tests.test_close.ClosingElement.close | ( | self | ) |
Release the resources the element holds.
The pipeline calls this when it is closed. This element holds none, and elements that hold native data or threads override it.
Reimplemented from fiftyone_pipeline_core.flowelement.FlowElement.
◆ process_internal()
| tests.test_close.ClosingElement.process_internal | ( | self, | |
| flowdata ) |
The method behind FlowElement.Process - it is called by the process() function.
It is usually overridden by specific flowElements to do their core work.
@type flowdata: FlowData
- Parameters
-
flowdata FlowData to be processed
@rtype: bool
- Returns
- : Returns True
Reimplemented from fiftyone_pipeline_core.flowelement.FlowElement.
Member Data Documentation
◆ closes
| int tests.test_close.ClosingElement.closes = 0 |