From d7df35fd2b8e7c71b84da22a3b59154746ecb9bd Mon Sep 17 00:00:00 2001 From: nlarge-google Date: Tue, 16 Aug 2022 16:39:54 +0000 Subject: [PATCH] Fix: Extended start year to resolve date truncation. --- .../pipelines/_images/run_csv_transform_kub/csv_transform.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datasets/new_york_taxi_trips/pipelines/_images/run_csv_transform_kub/csv_transform.py b/datasets/new_york_taxi_trips/pipelines/_images/run_csv_transform_kub/csv_transform.py index 8b30625e3..1fe72e229 100644 --- a/datasets/new_york_taxi_trips/pipelines/_images/run_csv_transform_kub/csv_transform.py +++ b/datasets/new_york_taxi_trips/pipelines/_images/run_csv_transform_kub/csv_transform.py @@ -87,7 +87,7 @@ def execute_pipeline( data_dtypes: dict, output_headers: typing.List[str], ) -> None: - for year_number in range(datetime.now().year, start_year, -1): + for year_number in range(datetime.now().year, (start_year - 1), -1): process_year_data( source_url=source_url, year_number=int(year_number),