1 -class IDataProcessor: 2 """ 3 A interface for all pipelines data processor 4 """ 5 - def run(self): 6 """ 7 run: process the data 8 """ 9 pass 10