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..635d602 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,7 @@ FROM `{{source_table}}` WHERE - DATE({{source_timestamp_field}}) BETWEEN '{{start_date}}' AND '{{end_date}}' + DATE({{source_timestamp_field}}) >= '{{start_date}}' < '{{end_date}}' """