diff --git a/models/staging/edfi_3/stage/stg_ef3__objective_assessments.sql b/models/staging/edfi_3/stage/stg_ef3__objective_assessments.sql index 9b92f0d4..7556a668 100644 --- a/models/staging/edfi_3/stage/stg_ef3__objective_assessments.sql +++ b/models/staging/edfi_3/stage/stg_ef3__objective_assessments.sql @@ -1,3 +1,5 @@ + -- depends_on: {{ ref('base_ef3__objective_assessments') }} + with base_obj_assessments as ( select * from {{ ref('base_ef3__objective_assessments') }} where not is_deleted @@ -41,6 +43,14 @@ keyed as ( 'lower(namespace)', 'lower(objective_assessment_identification_code)'] ) }} as k_objective_assessment, + {{ dbt_utils.generate_surrogate_key( + ['tenant_code', + 'api_year', + 'lower(academic_subject)', + 'lower(assessment_identifier)', + 'lower(namespace)', + 'lower(parent_objective_assessment_reference:identificationCode::varchar)'] + ) }} as k_parent_objective_assessment, {{ gen_skey('k_assessment', extras = ['academic_subject']) }}, join_subject.* {{ extract_extension(model_name=this.name, flatten=True) }}