diff --git a/dataflows/bank-processing/dataflow.yaml b/dataflows/bank-processing/dataflow.yaml
index 125c291..7cae455 100644
--- a/dataflows/bank-processing/dataflow.yaml
+++ b/dataflows/bank-processing/dataflow.yaml
@@ -268,7 +268,7 @@ services:
         transforms:
           - operator: filter-map
             run: |
-              fn generate_overdraft_event(ev: DataEvent) -> Result<Option<OverdraftEvent>> {
+              fn generate_overdraft_event_due_withdrawal(ev: DataEvent) -> Result<Option<OverdraftEvent>> {
 
                 let withdrawal = match ev.operation {
                   DataOperation::CreditAccount(_) => return Ok(None),
@@ -406,7 +406,7 @@ services:
         transforms:
           - operator: filter-map
             run: |
-              fn generate_overdraft_event(ev: DataEvent) -> Result<Option<OverdraftEvent>> {
+              fn generate_overdraft_event_due_transfer(ev: DataEvent) -> Result<Option<OverdraftEvent>> {
 
                 let withdrawal = match ev.operation {
                   DataOperation::CreditAccount(_) => return Ok(None),