functional_observer¶
Module that defines the FunctionalObserver class
-
class
tasrif.processing_pipeline.observers.functional_observer.FunctionalObserver¶ Interface specification of a observer The constructor of a concrete operator will provide options to configure the operation. The processing is invoked via the process method and the data to be processed is passed to the process method.
-
observe(operator, *data_frames)¶ Function that performs checks on operator and data frame before observation This observation is only performed on non-infrastructure operators
- Parameters
operator (ProcessingOperator) – Processing operator which is observed
*data_frames (list of pd.DataFrame) – Variable number of pandas dataframes to be observed
-