ntd: recast ntd_id as string (#3704)

* ntd: recast ntd_id as string * cast appropriately before using string handling macro
cal-itp · Feb 18, 2025 · ce476aa · ce476aa
1 parent 272e35c
commit ce476aa
Show file tree

Hide file tree

Showing 57 changed files with 81 additions and 81 deletions.
diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2022_agency_information.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2022_agency_information.sql
@@ -45,7 +45,7 @@ SELECT
     SAFE_CAST(volunteer_drivers AS NUMERIC) AS volunteer_drivers,
     {{ trim_make_empty_string_null('doing_business_as') }} AS doing_business_as,
     {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
-    {{ trim_make_empty_string_null('legacy_ntd_id') }} AS legacy_ntd_id,
+    {{ trim_make_empty_string_null('CAST(legacy_ntd_id AS STRING)') }} AS legacy_ntd_id,
     SAFE_CAST(total_voms AS INTEGER) AS total_voms,
     SAFE_CAST(primary_uza_uace_code AS NUMERIC) AS primary_uza_uace_code,
     {{ trim_make_empty_string_null('reported_by_name') }} AS reported_by_name,
@@ -54,7 +54,7 @@ SELECT
     SAFE_CAST(voms_pt AS NUMERIC) AS voms_pt,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('reported_by_ntd_id') }} AS reported_by_ntd_id,
     SAFE_CAST(density AS NUMERIC) AS density,
     {{ trim_make_empty_string_null('state_parent_ntd_id') }} AS state_parent_ntd_id,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2023_agency_information.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__2023_agency_information.sql
@@ -48,14 +48,14 @@ SELECT
     SAFE_CAST(volunteer_drivers AS NUMERIC) AS volunteer_drivers,
     {{ trim_make_empty_string_null('doing_business_as') }} AS doing_business_as,
     {{ trim_make_empty_string_null('reporter_type') }} AS reporter_type,
-    {{ trim_make_empty_string_null('legacy_ntd_id') }} AS legacy_ntd_id,
+    {{ trim_make_empty_string_null('CAST(legacy_ntd_id AS STRING)') }} AS legacy_ntd_id,
     SAFE_CAST(total_voms AS INTEGER) AS total_voms,
     SAFE_CAST(fta_recipient_id AS NUMERIC) AS fta_recipient_id,
     {{ trim_make_empty_string_null('city') }} AS city,
     SAFE_CAST(voms_pt AS NUMERIC) AS voms_pt,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     {{ trim_make_empty_string_null('agency_name') }} AS agency_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('reported_by_ntd_id') }} AS reported_by_ntd_id,
     SAFE_CAST(density AS NUMERIC) AS density,
     {{ trim_make_empty_string_null('state_parent_ntd_id') }} AS state_parent_ntd_id,

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('CAST(ntd_id AS STRING)') }} AS ntd_id,
     dt,
     execution_ts
 FROM stg_ntd__2023_contractual_relationships
diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__breakdowns.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__breakdowns.sql
@@ -24,7 +24,7 @@ SELECT
     {{ trim_make_empty_string_null('mode') }} AS mode,
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other_mechanical_failures AS NUMERIC) AS other_mechanical_failures,
     {{ trim_make_empty_string_null('other_mechanical_failures_1') }} AS other_mechanical_failures_1,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__breakdowns_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__breakdowns_by_agency.sql
@@ -31,7 +31,7 @@ SELECT
     {{ trim_make_empty_string_null('max_state') }} AS max_state,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_major_mechanical_failures AS NUMERIC) AS sum_major_mechanical_failures,
     SAFE_CAST(sum_other_mechanical_failures AS NUMERIC) AS sum_other_mechanical_failures,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_by_capital_use.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_by_capital_use.sql
@@ -33,7 +33,7 @@ SELECT
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
     {{ trim_make_empty_string_null('modecd') }} AS modecd,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other AS NUMERIC) AS other,
     {{ trim_make_empty_string_null('other_questionable') }} AS other_questionable,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_by_mode.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_by_mode.sql
@@ -36,7 +36,7 @@ SELECT
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
     {{ trim_make_empty_string_null('modecd') }} AS modecd,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_administrative_buildings AS NUMERIC) AS sum_administrative_buildings,
     SAFE_CAST(sum_communication_information AS NUMERIC) AS sum_communication_information,

diff --git a/...se/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_existing_service.sql b/...se/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_existing_service.sql
@@ -26,7 +26,7 @@ SELECT
     {{ trim_make_empty_string_null('max_state') }} AS max_state,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_administrative_buildings AS NUMERIC) AS sum_administrative_buildings,
     SAFE_CAST(sum_communication_information AS NUMERIC) AS sum_communication_information,

diff --git a/...odels/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_expansion_of_service.sql b/...odels/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_expansion_of_service.sql
@@ -26,7 +26,7 @@ SELECT
     {{ trim_make_empty_string_null('max_state') }} AS max_state,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_administrative_buildings AS NUMERIC) AS sum_administrative_buildings,
     SAFE_CAST(sum_communication_information AS NUMERIC) AS sum_communication_information,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_agency.sql
@@ -33,7 +33,7 @@ SELECT
     SAFE_CAST(max_agency_voms_1 AS NUMERIC) AS max_agency_voms_1,
     {{ trim_make_empty_string_null('max_city_1') }} AS max_city_1,
     SAFE_CAST(max_mode_voms AS NUMERIC) AS max_mode_voms,
-    {{ trim_make_empty_string_null('max_ntd_id') }} AS max_ntd_id,
+    {{ trim_make_empty_string_null('CAST(max_ntd_id AS STRING)') }} AS max_ntd_id,
     SAFE_CAST(max_primary_uza_population_1 AS NUMERIC) AS max_primary_uza_population_1,
     {{ trim_make_empty_string_null('max_state_1') }} AS max_state_1,
     {{ trim_make_empty_string_null('max_uza_name_1') }} AS max_uza_name_1,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode.sql
@@ -30,7 +30,7 @@ SELECT
     SAFE_CAST(count_vehicle_operations_hours_q AS NUMERIC) AS count_vehicle_operations_hours_q,
     {{ trim_make_empty_string_null('max_mode_name') }} AS max_mode_name,
     {{ trim_make_empty_string_null('mode') }} AS mode,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_total_employee_count AS NUMERIC) AS sum_total_employee_count,
     SAFE_CAST(sum_total_hours AS NUMERIC) AS sum_total_hours,

diff --git a/...ouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode_and_employee_type.sql b/...ouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode_and_employee_type.sql
@@ -35,7 +35,7 @@ SELECT
     {{ trim_make_empty_string_null('mode') }} AS mode,
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(primary_uza_population AS NUMERIC) AS primary_uza_population,
     SAFE_CAST(report_year AS INT64) AS report_year,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__fuel_and_energy.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__fuel_and_energy.sql
@@ -66,7 +66,7 @@ SELECT
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
     {{ trim_make_empty_string_null('modecd') }} AS modecd,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other_fuel AS NUMERIC) AS other_fuel,
     SAFE_CAST(other_fuel_mpg AS NUMERIC) AS other_fuel_mpg,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__fuel_and_energy_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__fuel_and_energy_by_agency.sql
@@ -27,7 +27,7 @@ SELECT
     {{ trim_make_empty_string_null('max_state') }} AS max_state,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_bio_diesel_gal AS NUMERIC) AS sum_bio_diesel_gal,
     SAFE_CAST(sum_compressed_natural_gas AS NUMERIC) AS sum_compressed_natural_gas,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_by_expense_type.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_by_expense_type.sql
@@ -26,7 +26,7 @@ SELECT
     {{ trim_make_empty_string_null('fund_expenditure_type') }} AS fund_expenditure_type,
     SAFE_CAST(local AS NUMERIC) AS local,
     {{ trim_make_empty_string_null('local_questionable') }} AS local_questionable,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(primary_uza_population AS NUMERIC) AS primary_uza_population,
     SAFE_CAST(report_year AS INT64) AS report_year,

diff --git a/...house/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_directly_generated.sql b/...house/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_directly_generated.sql
@@ -25,7 +25,7 @@ SELECT
     {{ trim_make_empty_string_null('concessions_questionable') }} AS concessions_questionable,
     SAFE_CAST(fares AS NUMERIC) AS fares,
     {{ trim_make_empty_string_null('fares_questionable') }} AS fares_questionable,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other AS NUMERIC) AS other,
     {{ trim_make_empty_string_null('other_questionable') }} AS other_questionable,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_federal.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_federal.sql
@@ -22,7 +22,7 @@ SELECT
     SAFE_CAST(fta_capital_program_5309 AS NUMERIC) AS fta_capital_program_5309,
     SAFE_CAST(fta_rural_progam_5311 AS NUMERIC) AS fta_rural_progam_5311,
     SAFE_CAST(fta_urbanized_area_formula AS NUMERIC) AS fta_urbanized_area_formula,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other_dot_funds AS NUMERIC) AS other_dot_funds,
     SAFE_CAST(other_federal_funds AS NUMERIC) AS other_federal_funds,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_local.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_local.sql
@@ -22,7 +22,7 @@ SELECT
     SAFE_CAST(fuel_tax AS NUMERIC) AS fuel_tax,
     SAFE_CAST(general_fund AS NUMERIC) AS general_fund,
     SAFE_CAST(income_tax AS NUMERIC) AS income_tax,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other_funds AS NUMERIC) AS other_funds,
     SAFE_CAST(other_taxes AS NUMERIC) AS other_taxes,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_state.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_state.sql
@@ -20,7 +20,7 @@ SELECT
     SAFE_CAST(agency_voms AS NUMERIC) AS agency_voms,
     {{ trim_make_empty_string_null('city') }} AS city,
     SAFE_CAST(general_funds AS NUMERIC) AS general_funds,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(primary_uza_population AS NUMERIC) AS primary_uza_population,
     SAFE_CAST(reduced_reporter_funds AS NUMERIC) AS reduced_reporter_funds,

diff --git a/...e/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_taxes_levied_by_agency.sql b/...e/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_taxes_levied_by_agency.sql
@@ -21,7 +21,7 @@ SELECT
     {{ trim_make_empty_string_null('city') }} AS city,
     SAFE_CAST(fuel_tax AS NUMERIC) AS fuel_tax,
     SAFE_CAST(income_tax AS NUMERIC) AS income_tax,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(other_funds AS NUMERIC) AS other_funds,
     SAFE_CAST(other_tax AS NUMERIC) AS other_tax,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__maintenance_facilities.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__maintenance_facilities.sql
@@ -34,7 +34,7 @@ SELECT
     {{ trim_make_empty_string_null('mode') }} AS mode,
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(over_300_vehicles AS NUMERIC) AS over_300_vehicles,
     {{ trim_make_empty_string_null('over_300_vehicles_questionable') }} AS over_300_vehicles_questionable,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__maintenance_facilities_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__maintenance_facilities_by_agency.sql
@@ -25,7 +25,7 @@ SELECT
     {{ trim_make_empty_string_null('max_state') }} AS max_state,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     SAFE_CAST(sum_200_to_300_vehicles AS NUMERIC) AS sum_200_to_300_vehicles,
     SAFE_CAST(sum_heavy_maintenance_facilities AS NUMERIC) AS sum_heavy_maintenance_facilities,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__metrics.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__metrics.sql
@@ -34,7 +34,7 @@ SELECT
     {{ trim_make_empty_string_null('mode') }} AS mode,
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(passenger_miles AS NUMERIC) AS passenger_miles,
     {{ trim_make_empty_string_null('passenger_miles_questionable') }} AS passenger_miles_questionable,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function.sql
@@ -26,7 +26,7 @@ SELECT
     {{ trim_make_empty_string_null('mode') }} AS mode,
     {{ trim_make_empty_string_null('mode_name') }} AS mode_name,
     SAFE_CAST(mode_voms AS NUMERIC) AS mode_voms,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     {{ trim_make_empty_string_null('organization_type') }} AS organization_type,
     SAFE_CAST(primary_uza_population AS NUMERIC) AS primary_uza_population,
     SAFE_CAST(reduced_reporter_expenses AS NUMERIC) AS reduced_reporter_expenses,

diff --git a/...odels/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function_and_agency.sql b/...odels/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function_and_agency.sql
@@ -24,7 +24,7 @@ SELECT
     {{ trim_make_empty_string_null('max_reporter_type') }} AS max_reporter_type,
     {{ trim_make_empty_string_null('max_uace_code') }} AS max_uace_code,
     {{ trim_make_empty_string_null('max_uza_name') }} AS max_uza_name,
-    {{ trim_make_empty_string_null('ntd_id') }} AS ntd_id,
+    {{ trim_make_empty_string_null('CAST(ntd_id AS STRING)') }} AS ntd_id,
     SAFE_CAST(report_year AS INT64) AS report_year,
     {{ trim_make_empty_string_null('state') }} AS state,
     SAFE_CAST(sum_facility_maintenance AS NUMERIC) AS sum_facility_maintenance,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__service_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__service_by_agency.sql
@@ -16,7 +16,7 @@ stg_ntd__service_by_agency AS (
 )
 
 SELECT
-    {{ trim_make_empty_string_null('_5_digit_ntd_id') }} AS _5_digit_ntd_id,
+    {{ trim_make_empty_string_null('CAST(_5_digit_ntd_id AS STRING)') }} AS _5_digit_ntd_id,
     {{ trim_make_empty_string_null('agency') }} AS agency,
     SAFE_CAST(max_agency_voms AS NUMERIC) AS max_agency_voms,
     {{ trim_make_empty_string_null('max_city') }} AS max_city,

diff --git a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__service_by_mode.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__service_by_mode.sql
@@ -16,7 +16,7 @@ stg_ntd__service_by_mode AS (
 )
 
 SELECT
-    {{ trim_make_empty_string_null('_5_digit_ntd_id') }} AS _5_digit_ntd_id,
+    {{ trim_make_empty_string_null('CAST(_5_digit_ntd_id AS STRING)') }} AS _5_digit_ntd_id,
     {{ trim_make_empty_string_null('max_agency') }} AS max_agency,
     SAFE_CAST(max_agency_voms AS NUMERIC) AS max_agency_voms,
     {{ trim_make_empty_string_null('max_city') }} AS max_city,

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('CAST(ntd_id AS STRING)') }} 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('CAST(ntd_id AS STRING)') }} 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('CAST(ntd_id AS STRING)') }} 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('CAST(ntd_id AS STRING)') }} 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
@@ -33,7 +33,7 @@ WITH
         SAFE_CAST(_2002 AS FLOAT64) AS _2002,
         SAFE_CAST(_2006 AS FLOAT64) AS _2006,
         SAFE_CAST(_2000 AS FLOAT64) AS _2000,
-        {{ trim_make_empty_string_null('legacy_ntd_id') }} AS legacy_ntd_id,
+        {{ trim_make_empty_string_null('CAST(legacy_ntd_id AS STRING)') }} AS legacy_ntd_id,
         SAFE_CAST(uace_code AS INT64) AS uace_code,
         SAFE_CAST(_2004 AS FLOAT64) AS _2004,
         SAFE_CAST(_1998 AS FLOAT64) AS _1998,
@@ -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('CAST(ntd_id AS STRING)') }} 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
@@ -33,7 +33,7 @@ WITH
         SAFE_CAST(_2002 AS FLOAT64) AS _2002,
         SAFE_CAST(_2006 AS FLOAT64) AS _2006,
         SAFE_CAST(_2000 AS FLOAT64) AS _2000,
-        {{ trim_make_empty_string_null('legacy_ntd_id') }} AS legacy_ntd_id,
+        {{ trim_make_empty_string_null('CAST(legacy_ntd_id AS STRING)') }} AS legacy_ntd_id,
         SAFE_CAST(uace_code AS INT64) AS uace_code,
         SAFE_CAST(_2004 AS FLOAT64) AS _2004,
         SAFE_CAST(_1998 AS FLOAT64) AS _1998,
@@ -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('CAST(ntd_id AS STRING)') }} 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,