from pipeline.main import TxnAnomalyPipeline
pipe = TxnAnomalyPipeline()
pipe.run()