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}}' """