text: {{ config(
      unique_key = env_var('AIRBYTE_DEFAULT_UNIQUE_KEY', '_airbyte_ab_id'),
      schema = "_airbyte_test_normalization",
      tags = [ "nested-intermediate" ]
  ) }}
  -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema
  select
      _airbyte_conflict_stream_name_2_hashid,
      {{ json_extract_scalar('conflict_stream_name', ['groups'], ['groups']) }} as groups,
      _airbyte_ab_id,
      _airbyte_emitted_at,
      {{ current_timestamp() }} as _airbyte_normalized_at
  from {{ ref('conflict_stream_name_conflict_stream_name') }} as table_alias
  -- conflict_stream_name at conflict_stream_name/conflict_stream_name/conflict_stream_name
  where 1 = 1
  and conflict_stream_name is not null
  
  