diff --git a/app/models/transaction.py b/app/models/transaction.py
index 7d1ce8d..eb8c03f 100644
--- a/app/models/transaction.py
+++ b/app/models/transaction.py
@@ -23,9 +23,14 @@ class Transaction(db.Model):
     @classmethod
     def create_transaction(cls, transaction_id, account_id, type, channel):
 
-        if cls.query.filter_by(transaction_id=transaction_id).first():
+        # if cls.query.filter_by(transaction_id=transaction_id).first():
+        #     raise ValueError("Duplicate Transaction")
+
+        if cls.query.filter( and_( transaction_id=transaction_id,type=type) ).first():
             raise ValueError("Duplicate Transaction")
 
+
+
         transaction = cls(
             transaction_id=transaction_id,
             account_id=account_id,