text: 
  
    create or replace table `dataline-integration-testing`.test_normalization.`conflict_stream_name_conflict_stream_name`
    partition by timestamp_trunc(_airbyte_emitted_at, day)
    cluster by _airbyte_emitted_at
    OPTIONS()
    as (
      
  -- Final base SQL model
  select
      _airbyte_conflict_stream_name_hashid,
      conflict_stream_name,
      _airbyte_ab_id,
      _airbyte_emitted_at,
      CURRENT_TIMESTAMP() as _airbyte_normalized_at,
      _airbyte_conflict_stream_name_2_hashid
  from `dataline-integration-testing`._airbyte_test_normalization.`conflict_stream_name_conflict_stream_name_ab3`
  -- conflict_stream_name at conflict_stream_name/conflict_stream_name from `dataline-integration-testing`.test_normalization.`conflict_stream_name`
  where 1 = 1
    );
      