diff --git a/transform/sqlmesh_padelnomics/models/staging/stg_playtomic_availability.sql b/transform/sqlmesh_padelnomics/models/staging/stg_playtomic_availability.sql index d6fa37d..64306b1 100644 --- a/transform/sqlmesh_padelnomics/models/staging/stg_playtomic_availability.sql +++ b/transform/sqlmesh_padelnomics/models/staging/stg_playtomic_availability.sql @@ -34,7 +34,7 @@ all_jsonl AS ( tenant_id, slots AS slots_json FROM read_json( - @LANDING_DIR || '/playtomic/*/*/availability_' || @start_ds || '*.jsonl.gz', + @LANDING_DIR || '/playtomic/*/*/availability_*.jsonl.gz', format = 'newline_delimited', columns = { date: 'VARCHAR', @@ -46,6 +46,7 @@ all_jsonl AS ( filename = true ) WHERE tenant_id IS NOT NULL + AND CAST(date AS DATE) BETWEEN @start_ds AND @end_ds ), raw_resources AS ( SELECT