diff --git a/db/repository.py b/db/repository.py index cb448c8..0216482 100644 --- a/db/repository.py +++ b/db/repository.py @@ -7,7 +7,7 @@ Handles CRUD operations and transaction management. from typing import List, Optional from logging_config import get_logger from .oracle_connector import get_connector -from .models import NEFTInwardRecord, ProcessedFile +from .models import NEFTOutwardRecord, ProcessedFile logger = get_logger(__name__) @@ -56,7 +56,7 @@ class Repository: # --------------------------------------------------------- # UPDATED: bulk_insert_transactions WITH VALIDATION # --------------------------------------------------------- - def bulk_insert_transactions(self, transactions: List[NEFTInwardRecord]) -> tuple: + def bulk_insert_transactions(self, transactions: List[NEFTOutwardRecord]) -> tuple: """ Bulk insert NEFT transactions into inward_neft_api_log. Records with invalid beneficiary account numbers are skipped. @@ -304,4 +304,4 @@ class Repository: finally: if cursor: cursor.close() - conn.close() \ No newline at end of file + conn.close()