From 3b4b58045cb33992d0430dc332bdf0236bda84e7 Mon Sep 17 00:00:00 2001 From: Rodrigo Fuentes Date: Mon, 1 Jul 2024 21:18:20 -0300 Subject: [PATCH] Exclude positions on end date during normalization --- .../vms_ingestion/normalization/transforms/read_source.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/pipe-vms-ingestion/vms_ingestion/normalization/transforms/read_source.py b/packages/pipe-vms-ingestion/vms_ingestion/normalization/transforms/read_source.py index 177b313..a029973 100644 --- a/packages/pipe-vms-ingestion/vms_ingestion/normalization/transforms/read_source.py +++ b/packages/pipe-vms-ingestion/vms_ingestion/normalization/transforms/read_source.py @@ -11,7 +11,8 @@ FROM `{{source_table}}` WHERE - DATE({{source_timestamp_field}}) BETWEEN '{{start_date}}' AND '{{end_date}}' + DATE({{source_timestamp_field}}) >= '{{start_date}}' + AND DATE({{source_timestamp_field}}) < '{{end_date}}' """