from pipeline.main import TxnAnomalyPipeline
if __name__ == '__main__':
    pipe = TxnAnomalyPipeline()
    pipe.run()