dbt platformでジョブをエラー終了させずに祝日のみ更新する方法を実装してみた

【処理フロー】
祝日の場合:
  dbt run → is_today_holiday() = true → seedから最新データを取得 → テーブル更新

祝日ではない場合:
  dbt run → is_today_holiday() = false → 既存テーブル相当の内容を返す → 実質的に変更なし（dbtの実行自体は行う）

{#
  ============================================================================
  is_today_holiday マクロ
  ============================================================================
  概要:
    今日が祝日かどうかを判定し、true/false を返す
    Jinja の if 文で分岐処理に使用可能

  使用方法:
    {% if is_today_holiday() %}
      -- 祝日の処理
    {% else %}
      -- 祝日でない日の処理（または何もしない）
    {% endif %}

  戻り値:
    祝日の場合: true
    祝日でない日の場合: false
#}
{% macro is_today_holiday() %}
    {% set is_holiday_query %}
        select count(*) as cnt
        from {{ target.database }}.DBT_TKAWABATA.JAPANESE_HOLIDAYS
        where holiday_date = DATE(CONVERT_TIMEZONE('UTC', 'Asia/Tokyo', CURRENT_TIMESTAMP()))
    {% endset %}

    {% if execute %}
        {% set result = run_query(is_holiday_query) %}
        {% set holiday_count = result.columns[0].values()[0] %}
        {{ return(holiday_count > 0) }}
    {% else %}
        {{ return(false) }}
    {% endif %}
{% endmacro %}

{#
  ============================================================================
incremental_dim_holidays - 日本の祝日マスターテーブル
  ============================================================================
  概要:
    日本の祝日データを管理するディメンションテーブル

  動作:
    - 初回実行/フルリフレッシュ: seedから全データをロード
    - 増分実行 + 祝日: seed全件をソースとしてMERGEし、既存行を更新・新規行を追加
    - 増分実行 + 祝日でない日: where 1=0 により何も追加せず既存データを維持
    - この例では差分抽出は行わず、incremental materialization を“条件付き更新制御”のために使っています
#}

{{ config(
    materialized='incremental',
    unique_key='holiday_date'
) }}

with source_data as (
    select
        holiday_date,
        holiday_name,
        holiday_type,
        extract(year from holiday_date) as holiday_year,
        extract(month from holiday_date) as holiday_month,
        dayname(holiday_date) as day_of_week
    from {{ ref('japanese_holidays') }}
)

select * from source_data
{% if is_incremental() and not is_today_holiday() %}
    where 1 = 0  -- 祝日でない日の増分実行時は何も追加しない
{% endif %}

{#
  ============================================================================
  dim_holidays - 日本の祝日マスターテーブル
  ============================================================================
  概要:
    日本の祝日データを管理するディメンションテーブル

  動作:
    - 祝日の場合: seedデータから最新の祝日マスターを再構築
    - 祝日でない日の場合: 既存テーブルと同等の内容で再作成し、結果として実質的なデータ変更を発生させない
#}

-- depends_on: {{ ref('japanese_holidays') }}

{{ config(
    materialized='table'
) }}

{% if is_today_holiday() %}
    {# === 祝日の場合: seedから最新データを取得して更新 === #}
    {{ log("Today is a holiday! Updating dim_holidays table.", info=True) }}

    select
        holiday_date,
        holiday_name,
        holiday_type,
        extract(year from holiday_date) as holiday_year,
        extract(month from holiday_date) as holiday_month,
        dayname(holiday_date) as day_of_week
    from {{ ref('japanese_holidays') }}

{% else %}
    {# === 祝日でない日の場合: 既存テーブルと同等の内容を返し、実質的な変更を発生させない === #}
    {{ log("Today is not a holiday. Keeping existing dim_holidays data.", info=True) }}

    select
        holiday_date,
        holiday_name,
        holiday_type,
        holiday_year,
        holiday_month,
        day_of_week
    from {{ target.database }}.DBT_TKAWABATA.dim_holidays

{% endif %}

dbt run --select incremental_dim_holidays --full-refresh

dbt run --select incremental_dim_holidays

dbt run --select incremental_dim_holidays

# 祝日の場合
Today is a holiday! Updating dim_holidays table.

# 祝日ではない日の場合
Today is not a holiday. Keeping existing dim_holidays data.