update history staging models with correct active records

CHANGELOG.md

@@ -1,3 +1,12 @@
+# dbt_workday v0.1.1
+
+[PR #4](https://github.com/fivetran/dbt_workday/pull/4) contains the following updates:
+## Bug Fixes
+- Updates the filtering done in the history staging models to pull the correct active statuses. Since some changes are entered but not yet effective, we needed to replace the `_fivetran_active` filter to where current timestamp is between `_fivetran_start` and `_fivetran_end` times for each record.
+
+## Under the Hood
+- Switched from using `dbt.current_timestamp_backcompat()` to `dbt.current_timestamp()` since the former has since been deprecated and was just previously used to ensure Snowflake and Postgres compatibility. 
+
 # dbt_workday v0.1.0
 
 ## 🎉 Initial Release 🎉

dbt_project.yml

@@ -1,6 +1,6 @@
 config-version: 2
 name: 'workday'
-version: '0.1.0'
+version: '0.1.1'
 require-dbt-version: [">=1.3.0", "<2.0.0"]
 
 models:

integration_tests/dbt_project.yml

@@ -1,5 +1,5 @@
 name: 'workday_integration_tests'
-version: '0.1.0'
+version: '0.1.1'
 config-version: 2
 
 profile: 'integration_tests'

models/intermediate/int_workday__worker_details.sql

@@ -2,7 +2,7 @@ with worker_data as (
 
     select 
         *,
-        {{ dbt.current_timestamp_backcompat() }} as current_date
+        {{ dbt.current_timestamp() }} as current_date
     from {{ ref('stg_workday__worker') }}
 ),
 

models/intermediate/int_workday__worker_position_enriched.sql

@@ -2,7 +2,7 @@ with worker_position_data as (
 
     select 
         *,
-        {{ dbt.current_timestamp_backcompat() }} as current_date
+        {{ dbt.current_timestamp() }} as current_date
     from {{ ref('stg_workday__worker_position') }}
 ),
 

models/staging/stg_workday__personal_information.sql

@@ -60,7 +60,7 @@ final as (
         tobacco_use as is_tobacco_use,
         type
     from fields
-    where coalesce(_fivetran_active, true)
+    where {{ dbt.current_timestamp() }} between _fivetran_start and _fivetran_end
 )
 
 select *

models/staging/stg_workday__worker.sql

@@ -110,7 +110,7 @@ final as (
         vesting_date,
         worker_code
     from fields
-    where coalesce(_fivetran_active, true)
+    where {{ dbt.current_timestamp() }} between _fivetran_start and _fivetran_end
 )
 
 select *

models/staging/stg_workday__worker_position.sql

@@ -85,7 +85,7 @@ final as (
         working_time_unit,
         working_time_value
     from fields
-    where coalesce(_fivetran_active, true)
+    where {{ dbt.current_timestamp() }} between _fivetran_start and _fivetran_end
 )
 
 select *

models/staging/stg_workday__worker_position_organization.sql

@@ -34,7 +34,7 @@ final as (
         primary_business_site,
         used_in_change_organization_assignments as is_used_in_change_organization_assignments
     from fields
-    where coalesce(_fivetran_active, true)
+    where {{ dbt.current_timestamp() }} between _fivetran_start and _fivetran_end
 )
 
 select *