ntd: recast ntd_id as string

cal-itp · Feb 18, 2025 · 6de344e · 6de344e
1 parent 272e35c
commit 6de344e
Show file tree

Hide file tree

Showing 31 changed files with 31 additions and 31 deletions.
diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2023_contractual_relationships.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2023_contractual_relationships.sql
@@ -42,7 +42,7 @@ SELECT
     {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
     {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
     {{ trim_make_empty_string_null('other_public_assets_provided_desc') }} AS other_public_assets_provided_desc,
-    SAFE_CAST(ntd_id AS INTEGER) AS ntd_id,
+    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
     dt,
     execution_ts
 FROM stg_ntd__2023_contractual_relationships
diff --git a/...taging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__facilities.sql b/...taging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__facilities.sql
@@ -64,7 +64,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__capital_expenditures_time_series__facilities
diff --git a/...els/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__other.sql b/...els/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__other.sql
@@ -64,7 +64,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__capital_expenditures_time_series__other
diff --git a/...ing/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__rolling_stock.sql b/...ing/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__rolling_stock.sql
@@ -64,7 +64,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__capital_expenditures_time_series__rolling_stock
diff --git a/...els/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__total.sql b/...els/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__total.sql
@@ -64,7 +64,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__capital_expenditures_time_series__total
diff --git a/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_federal.sql b/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_federal.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_local.sql b/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_local.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.sql b/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.sql b/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.sql b/...unding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...ses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql b/...ses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql
@@ -58,7 +58,7 @@ WITH
         {{ trim_make_empty_string_null('state') }} AS state,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares
diff --git a/...ses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql b/...ses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql
@@ -58,7 +58,7 @@ WITH
         {{ trim_make_empty_string_null('state') }} AS state,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother
diff --git a/...ng_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_federal.sql b/...ng_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_federal.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.sql b/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.sql b/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.sql b/...ding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.sql
@@ -50,7 +50,7 @@ WITH
         SAFE_CAST(_2015 AS FLOAT64) AS _2015,
         SAFE_CAST(_1995 AS FLOAT64) AS _1995,
         SAFE_CAST(_1994 AS FLOAT64) AS _1994,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         {{ trim_make_empty_string_null('_2023_status') }} AS _2023_status,
         {{ trim_make_empty_string_null('agency_status') }} AS agency_status,
         SAFE_CAST(_1992 AS FLOAT64) AS _1992,

diff --git a/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql b/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm
diff --git a/..._and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql b/..._and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares
diff --git a/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql b/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga
diff --git a/..._expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql b/..._expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm
diff --git a/...xpenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql b/...xpenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total
diff --git a/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql b/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm
diff --git a/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql b/...d_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo
diff --git a/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql b/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt
diff --git a/...g_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql b/...g_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms
diff --git a/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql b/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh
diff --git a/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql b/...ng_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql
@@ -67,7 +67,7 @@ WITH
         {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module,
         {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
         {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-        SAFE_CAST(ntd_id AS FLOAT64) AS ntd_id,
+        {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
         dt,
         execution_ts
     FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm
diff --git a/...els/staging/ntd_safety_and_security/stg_ntd__fra_regulated_mode_major_security_events.sql b/...els/staging/ntd_safety_and_security/stg_ntd__fra_regulated_mode_major_security_events.sql
@@ -104,7 +104,7 @@ SELECT
     SAFE_CAST(other_fatalities AS INTEGER) AS other_fatalities,
     SAFE_CAST(pedestrian_not_in_crosswalk AS INTEGER) AS pedestrian_not_in_crosswalk,
     SAFE_CAST(number_of_derailed_cars AS NUMERIC) AS number_of_derailed_cars,
-    SAFE_CAST(ntd_id AS INTEGER) AS ntd_id,
+    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
     dt,
     execution_ts
 FROM stg_ntd__fra_regulated_mode_major_security_events
diff --git a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__major_safety_events.sql b/warehouse/models/staging/ntd_safety_and_security/stg_ntd__major_safety_events.sql
@@ -35,7 +35,7 @@ SELECT
     {{ trim_make_empty_string_null('typeofservicecd') }} AS typeofservicecd,
     {{ trim_make_empty_string_null('reportername') }} AS reportername,
     SAFE_CAST(customer AS INTEGER) AS customer,
-    SAFE_CAST(ntdid AS INTEGER) AS ntdid,
+    {{ trim_make_empty_string_null('ntdid') }} AS ntdid,
     dt,
     execution_ts
 FROM stg_ntd__major_safety_events
diff --git a/...staging/ntd_safety_and_security/stg_ntd__monthly_modal_time_series_safety_and_service.sql b/...staging/ntd_safety_and_security/stg_ntd__monthly_modal_time_series_safety_and_service.sql
@@ -85,7 +85,7 @@ SELECT
     SAFE_CAST(pedestrian_crossing_tracks_1 AS INTEGER) AS pedestrian_crossing_tracks_1,
     SAFE_CAST(primary_uza_sq_miles AS NUMERIC) AS primary_uza_sq_miles,
     {{ trim_make_empty_string_null('primary_uza_name') }} AS primary_uza_name,
-    SAFE_CAST(_5_digit_ntd_id AS INTEGER) AS _5_digit_ntd_id,
+    {{ trim_make_empty_string_null('_5_digit_ntd_id') }} AS _5_digit_ntd_id,
     SAFE_CAST(total_other_injuries AS INTEGER) AS total_other_injuries,
     SAFE_CAST(other_fatalities AS INTEGER) AS other_fatalities,
     SAFE_CAST(pedestrian_not_in_crosswalk AS INTEGER) AS pedestrian_not_in_crosswalk,

diff --git a/...e/models/staging/ntd_safety_and_security/stg_ntd__nonmajor_safety_and_security_events.sql b/...e/models/staging/ntd_safety_and_security/stg_ntd__nonmajor_safety_and_security_events.sql
@@ -57,7 +57,7 @@ SELECT
     SAFE_CAST(pederstiran_in_crosswalk AS INTEGER) AS pederstiran_in_crosswalk,
     SAFE_CAST(__computed_region_8fe2_rd7y AS NUMERIC) AS __computed_region_8fe2_rd7y,
     SAFE_CAST(bicyclist_injuries AS INTEGER) AS bicyclist_injuries,
-    SAFE_CAST(_5_digit_ntd_id AS INTEGER) AS _5_digit_ntd_id,
+    {{ trim_make_empty_string_null('_5_digit_ntd_id') }} AS _5_digit_ntd_id,
     SAFE_CAST(transit_employee_serious AS INTEGER) AS transit_employee_serious,
     SAFE_CAST(transit_employee_injuries AS INTEGER) AS transit_employee_injuries,
     SAFE_CAST(trespasser_serious_injuries_subtotal_ AS INTEGER) AS trespasser_serious_injuries_subtotal_,