From ce476aadc536511318f72ccd652349db2e051ae8 Mon Sep 17 00:00:00 2001 From: Charlie Costanzo Date: Tue, 18 Feb 2025 12:57:45 -0500 Subject: [PATCH] ntd: recast ntd_id as string (#3704) * ntd: recast ntd_id as string * cast appropriately before using string handling macro --- .../ntd_annual_reporting/stg_ntd__2022_agency_information.sql | 4 ++-- .../ntd_annual_reporting/stg_ntd__2023_agency_information.sql | 4 ++-- .../stg_ntd__2023_contractual_relationships.sql | 2 +- .../staging/ntd_annual_reporting/stg_ntd__breakdowns.sql | 2 +- .../ntd_annual_reporting/stg_ntd__breakdowns_by_agency.sql | 2 +- .../stg_ntd__capital_expenses_by_capital_use.sql | 2 +- .../stg_ntd__capital_expenses_by_mode.sql | 2 +- .../stg_ntd__capital_expenses_for_existing_service.sql | 2 +- .../stg_ntd__capital_expenses_for_expansion_of_service.sql | 2 +- .../ntd_annual_reporting/stg_ntd__employees_by_agency.sql | 2 +- .../ntd_annual_reporting/stg_ntd__employees_by_mode.sql | 2 +- .../stg_ntd__employees_by_mode_and_employee_type.sql | 2 +- .../staging/ntd_annual_reporting/stg_ntd__fuel_and_energy.sql | 2 +- .../stg_ntd__fuel_and_energy_by_agency.sql | 2 +- .../stg_ntd__funding_sources_by_expense_type.sql | 2 +- .../stg_ntd__funding_sources_directly_generated.sql | 2 +- .../ntd_annual_reporting/stg_ntd__funding_sources_federal.sql | 2 +- .../ntd_annual_reporting/stg_ntd__funding_sources_local.sql | 2 +- .../ntd_annual_reporting/stg_ntd__funding_sources_state.sql | 2 +- .../stg_ntd__funding_sources_taxes_levied_by_agency.sql | 2 +- .../ntd_annual_reporting/stg_ntd__maintenance_facilities.sql | 2 +- .../stg_ntd__maintenance_facilities_by_agency.sql | 2 +- .../models/staging/ntd_annual_reporting/stg_ntd__metrics.sql | 2 +- .../stg_ntd__operating_expenses_by_function.sql | 2 +- .../stg_ntd__operating_expenses_by_function_and_agency.sql | 2 +- .../ntd_annual_reporting/stg_ntd__service_by_agency.sql | 2 +- .../staging/ntd_annual_reporting/stg_ntd__service_by_mode.sql | 2 +- .../stg_ntd__capital_expenditures_time_series__facilities.sql | 2 +- .../stg_ntd__capital_expenditures_time_series__other.sql | 2 +- ...g_ntd__capital_expenditures_time_series__rolling_stock.sql | 2 +- .../stg_ntd__capital_expenditures_time_series__total.sql | 2 +- ...ating_and_capital_funding_time_series__capital_federal.sql | 4 ++-- ...erating_and_capital_funding_time_series__capital_local.sql | 4 ++-- ...erating_and_capital_funding_time_series__capital_other.sql | 4 ++-- ...erating_and_capital_funding_time_series__capital_state.sql | 4 ++-- ...erating_and_capital_funding_time_series__capital_total.sql | 4 ++-- ...tal_funding_time_series__decommissioned_operatingfares.sql | 4 ++-- ...tal_funding_time_series__decommissioned_operatingother.sql | 4 ++-- ...ing_and_capital_funding_time_series__operating_federal.sql | 4 ++-- ...ating_and_capital_funding_time_series__operating_other.sql | 4 ++-- ...ating_and_capital_funding_time_series__operating_state.sql | 4 ++-- ...ating_and_capital_funding_time_series__operating_total.sql | 4 ++-- ...e_data_and_operating_expenses_time_series_by_mode__drm.sql | 4 ++-- ...data_and_operating_expenses_time_series_by_mode__fares.sql | 4 ++-- ...a_and_operating_expenses_time_series_by_mode__opexp_ga.sql | 4 ++-- ..._and_operating_expenses_time_series_by_mode__opexp_nvm.sql | 4 ++-- ...nd_operating_expenses_time_series_by_mode__opexp_total.sql | 4 ++-- ...a_and_operating_expenses_time_series_by_mode__opexp_vm.sql | 4 ++-- ...a_and_operating_expenses_time_series_by_mode__opexp_vo.sql | 4 ++-- ...e_data_and_operating_expenses_time_series_by_mode__upt.sql | 4 ++-- ..._data_and_operating_expenses_time_series_by_mode__voms.sql | 4 ++-- ...e_data_and_operating_expenses_time_series_by_mode__vrh.sql | 4 ++-- ...e_data_and_operating_expenses_time_series_by_mode__vrm.sql | 4 ++-- .../stg_ntd__fra_regulated_mode_major_security_events.sql | 2 +- .../ntd_safety_and_security/stg_ntd__major_safety_events.sql | 2 +- .../stg_ntd__monthly_modal_time_series_safety_and_service.sql | 2 +- .../stg_ntd__nonmajor_safety_and_security_events.sql | 2 +- 57 files changed, 81 insertions(+), 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 index 2f3373bf6a..ff595cf146 100644 --- 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 index 45a3783d6c..df450200db 100644 --- 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 index e7a2a7fbdb..38bbaa03bf 100644 --- 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 index 7ad300df0f..96cf50a010 100644 --- 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 index b5b58271db..4a7bf6b993 100644 --- 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 index 38c9370860..1f8a594902 100644 --- 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 index cc696bcf25..d097da09d2 100644 --- 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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_existing_service.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_existing_service.sql index d57f322ec5..b050203872 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_existing_service.sql +++ b/warehouse/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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_expansion_of_service.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_expansion_of_service.sql index 10d777e84a..8aed2709fe 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__capital_expenses_for_expansion_of_service.sql +++ b/warehouse/models/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 index 981b5025ba..a6964bd5c9 100644 --- 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 index d6badb8656..8f1f5bdea6 100644 --- 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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode_and_employee_type.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode_and_employee_type.sql index e273bf89db..342daac711 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__employees_by_mode_and_employee_type.sql +++ b/warehouse/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 index 9f2ae3c4c8..1fab5815a3 100644 --- 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 index 1130e75f11..f6d1bc4496 100644 --- 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 index c0a58fc083..771dad95c5 100644 --- 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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_directly_generated.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_directly_generated.sql index df89d54dbc..00ef7b6934 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_directly_generated.sql +++ b/warehouse/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 index ad923167a9..2e3353809d 100644 --- 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 index 0896c4ba98..c1ffd6665b 100644 --- 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 index 3a528a1659..d08fb0a9bf 100644 --- 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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_taxes_levied_by_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_taxes_levied_by_agency.sql index d66bdcc67d..e58314f0e4 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__funding_sources_taxes_levied_by_agency.sql +++ b/warehouse/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 index 2213373694..3281af9d21 100644 --- 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 index a6d4503c42..a7558ee0ca 100644 --- 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 index 7ca6bb6c6d..c0e895078b 100644 --- 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 index 02c1a38838..e521d785f8 100644 --- 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/warehouse/models/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function_and_agency.sql b/warehouse/models/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function_and_agency.sql index 7b68cb175d..3d017b3ad6 100644 --- a/warehouse/models/staging/ntd_annual_reporting/stg_ntd__operating_expenses_by_function_and_agency.sql +++ b/warehouse/models/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 index 5a64346746..974d923e07 100644 --- 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 index fb819f81ea..d5d8af9cd5 100644 --- 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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__facilities.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__facilities.sql index 1b0548c12c..cfd4e2beca 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__facilities.sql +++ b/warehouse/models/staging/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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__other.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__other.sql index d006f698ee..81c9c37572 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__other.sql +++ b/warehouse/models/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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__rolling_stock.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__rolling_stock.sql index 7a8628a785..1aacffb018 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__rolling_stock.sql +++ b/warehouse/models/staging/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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__total.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__total.sql index cb74273d53..5afbdaadc9 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__capital_expenditures_time_series__total.sql +++ b/warehouse/models/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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_federal.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_federal.sql index 3d6b8c16ea..5a2b5402ae 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_federal.sql +++ b/warehouse/models/staging/ntd_funding_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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_local.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_local.sql index cae336a9ff..1667551cfb 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_local.sql +++ b/warehouse/models/staging/ntd_funding_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, diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.sql index 144392cfde..5d7f77f1db 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_other.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.sql index 0e1d7babdc..307cfe5109 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_state.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.sql index dc18044fc1..ce800fe8f2 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__capital_total.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql index 821d6e9c2b..b7a027ed86 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares.sql @@ -50,7 +50,7 @@ WITH SAFE_CAST(_1998 AS FLOAT64) AS _1998, SAFE_CAST(_2015 AS FLOAT64) AS _2015, {{ trim_make_empty_string_null('primary_uza_name') }} AS primary_uza_name, - {{ 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(census_year AS INT64) AS census_year, SAFE_CAST(_1993 AS FLOAT64) AS _1993, {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingfares diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql index 8732547e85..02c2675ad6 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother.sql @@ -50,7 +50,7 @@ WITH SAFE_CAST(_1998 AS FLOAT64) AS _1998, SAFE_CAST(_2015 AS FLOAT64) AS _2015, {{ trim_make_empty_string_null('primary_uza_name') }} AS primary_uza_name, - {{ 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(census_year AS INT64) AS census_year, SAFE_CAST(_1993 AS FLOAT64) AS _1993, {{ trim_make_empty_string_null('reporting_module') }} AS reporting_module, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__operating_and_capital_funding_time_series__decommissioned_operatingother diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_federal.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_federal.sql index 56f96728af..ca68e8443a 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_federal.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.sql index b95ee29d28..a96332bb12 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_other.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.sql index b37c433c48..da41db393f 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_state.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.sql index 8fb17e318e..80974a4ae9 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__operating_and_capital_funding_time_series__operating_total.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/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql index 6b4aeceb8a..96438848c5 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__drm diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql index 333d490db8..5f946b9f86 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares.sql @@ -31,7 +31,7 @@ WITH SAFE_CAST(_2002 AS FLOAT64) AS _2002, SAFE_CAST(_2006 AS FLOAT64) AS _2006, {{ trim_make_empty_string_null('_2000') }} 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, {{ trim_make_empty_string_null('_1998') }} AS _1998, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__fares diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql index a494434c0f..a0988b4845 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_ga diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql index 3a1f24609c..1567c71e8d 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_nvm diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql index 4caf055983..1c21260547 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_total diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql index fcb89fe2ac..b3c453bd94 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vm diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql index 83a4f12256..330bc7387c 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__opexp_vo diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql index f01a67b2ee..555fd8aaa9 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__upt diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql index 586e86bdd3..572ba7d24b 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__voms diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql index 21c2fffca8..2d03a2b9f7 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrh diff --git a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql index 318e762222..482934d023 100644 --- a/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql +++ b/warehouse/models/staging/ntd_funding_and_expenses/stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm.sql @@ -31,7 +31,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, @@ -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('CAST(ntd_id AS STRING)') }} AS ntd_id, dt, execution_ts FROM stg_ntd__service_data_and_operating_expenses_time_series_by_mode__vrm diff --git a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__fra_regulated_mode_major_security_events.sql b/warehouse/models/staging/ntd_safety_and_security/stg_ntd__fra_regulated_mode_major_security_events.sql index 3595e3fa38..ba2097dada 100644 --- a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__fra_regulated_mode_major_security_events.sql +++ b/warehouse/models/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('CAST(ntd_id AS STRING)') }} 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 index 3c71353e8d..bafb17f541 100644 --- 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('CAST(ntdid AS STRING)') }} AS ntdid, dt, execution_ts FROM stg_ntd__major_safety_events diff --git a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__monthly_modal_time_series_safety_and_service.sql b/warehouse/models/staging/ntd_safety_and_security/stg_ntd__monthly_modal_time_series_safety_and_service.sql index 31c8f2cb1c..664f0ee63b 100644 --- a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__monthly_modal_time_series_safety_and_service.sql +++ b/warehouse/models/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('CAST(_5_digit_ntd_id AS STRING)') }} 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/warehouse/models/staging/ntd_safety_and_security/stg_ntd__nonmajor_safety_and_security_events.sql b/warehouse/models/staging/ntd_safety_and_security/stg_ntd__nonmajor_safety_and_security_events.sql index e707a85ed6..bd3d00a797 100644 --- a/warehouse/models/staging/ntd_safety_and_security/stg_ntd__nonmajor_safety_and_security_events.sql +++ b/warehouse/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('CAST(_5_digit_ntd_id AS STRING)') }} 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_,