From 29e23ca9aa3332e4a2ccd0f38f86fa818169c18c Mon Sep 17 00:00:00 2001
From: george li <george.li98@gmail.com>
Date: Wed, 13 Nov 2024 23:53:31 -0500
Subject: [PATCH] fix normalization increasing state bug

---
 src/normalize/normalize.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/normalize/normalize.py b/src/normalize/normalize.py
index c17363e..7ea0b21 100644
--- a/src/normalize/normalize.py
+++ b/src/normalize/normalize.py
@@ -113,7 +113,7 @@ def parse_files(s3, s3_fs, source_prefix, destination_prefix, start_date, state_
         max_epoch_timestamp = cur_processing.timestamp()
 
         for page in paginator.paginate(Bucket=source_bucket, Prefix=date_partition, PaginationConfig={'PageSize': 60}):
-                trip_updates_pa = None
+            trip_updates_pa = None
             vehicles_pa = None
             alerts_pa = None