/** * WPML compatibility functions * * @global array $duplicated_posts Array to store the posts being duplicated. * * @package Yoast\WP\Duplicate_Post * @since 3.2 */ add_action( 'admin_init', 'duplicate_post_wpml_init' ); /** * Add handlers for WPML compatibility. */ function duplicate_post_wpml_init() { if ( defined( 'ICL_SITEPRESS_VERSION' ) ) { add_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'shutdown', 'duplicate_wpml_string_packages', 11 ); } } global $duplicated_posts; // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: Renaming a global variable is a BC break. $duplicated_posts = []; /** * Copy post translations. * * @global SitePress $sitepress Instance of the Main WPML class. * @global array $duplicated_posts Array of duplicated posts. * * @param int $post_id ID of the copy. * @param WP_Post $post Original post object. * @param string $status Status of the new post. */ function duplicate_post_wpml_copy_translations( $post_id, $post, $status = '' ) { global $sitepress; global $duplicated_posts; remove_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10 ); remove_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10 ); $current_language = $sitepress->get_current_language(); $trid = $sitepress->get_element_trid( $post->ID ); if ( ! empty( $trid ) ) { $translations = $sitepress->get_element_translations( $trid ); $new_trid = $sitepress->get_element_trid( $post_id ); foreach ( $translations as $code => $details ) { if ( $code !== $current_language ) { if ( $details->element_id ) { $translation = get_post( $details->element_id ); if ( ! $translation ) { continue; } $new_post_id = duplicate_post_create_duplicate( $translation, $status ); if ( ! is_wp_error( $new_post_id ) ) { $sitepress->set_element_language_details( $new_post_id, 'post_' . $translation->post_type, $new_trid, $code, $current_language ); } } } } // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: see above. $duplicated_posts[ $post->ID ] = $post_id; } } /** * Duplicate string packages. * * @global array() $duplicated_posts Array of duplicated posts. */ function duplicate_wpml_string_packages() { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: renaming the function would be a BC-break. global $duplicated_posts; foreach ( $duplicated_posts as $original_post_id => $duplicate_post_id ) { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $original_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $original_post_id ); // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $new_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $duplicate_post_id ); if ( is_array( $original_string_packages ) ) { foreach ( $original_string_packages as $original_string_package ) { $translated_original_strings = $original_string_package->get_translated_strings( [] ); foreach ( $new_string_packages as $new_string_package ) { $cache = new WPML_WP_Cache( 'WPML_Package' ); $cache->flush_group_cache(); $new_strings = $new_string_package->get_package_strings(); foreach ( $new_strings as $new_string ) { if ( isset( $translated_original_strings[ $new_string->name ] ) ) { foreach ( $translated_original_strings[ $new_string->name ] as $language => $translated_string ) { do_action( // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. 'wpml_add_string_translation', $new_string->id, $language, $translated_string['value'], $translated_string['status'] ); } } } } } } } } nlq-devテスト方針 – Raqqa

nlq-devテスト方針

0) 前提・観測の準備(環境が正しいか)

  • nlq-dev が起動している
  • dev-portal が到達可能(http mode の場合)
  • decikg が到達可能(http mode の場合)
  • metabase が到達可能
  • chroma(nlq 側の差分保存先)が到達可能
  • trace / request_id / run_id で一連を追える状態(ログ相関)

成果物:
「この環境では E2E を回せる」ことの確認(疎通・設定値・ログ相関キー)


1) ルーティング分岐の確認(質問→DeciKG or Dev-Portal)

  • 同じ “質問入力” で、route が期待通りに選ばれること
    • SQL_ONLY / CYPHER_ONLY / HYBRID(あなたの設計上の分岐)
  • stub/dummy の挙動(本番は http、ローカルは dummy でも可)を確認
  • 失敗時でも API 契約上のレスポンス形が崩れないこと(UIが止まらない)

成果物:
「質問 → route 決定」が正しい証跡(route / stub_used / reason / timings)


2) Dev-Portal 連携の確認(質問の受け渡し→SQL生成→SQL結果受領)

Dev-Portal ルートの場合に限って確認する工程。

  • nlq-dev → dev-portal に **質問(question)**が渡っている
  • dev-portal が生成した SQL を nlq-dev が受領できる
  • 実行結果(rows/columns/row_count 等)が nlq-dev に戻る
  • dry_run と本実行の差異(本番前提に合わせる)

成果物:
「入力 question → 生成SQL → 実行結果」が揃った証跡(SQL/結果/diagnostics)


3) Metabase グラフ作成(結果データ→可視化オブジェクト生成)

  • nlq-dev が受領した tabular result を元に
    • 既存カード更新 or 新規カード作成
    • 表示タイプ(time_series / ranking / scalar 等)が想定通り
  • Metabase 側でカード/ダッシュボードが参照可能
  • 同じ質問で “同じカードに更新” か “新カード作成” かの方針通り

成果物:
Metabase 上の成果物(card_id / url / dataset hash など)と、nlq-dev 側の対応づけ


4) コメント作成(生成コメント→保存)

  • nlq-dev が結果からコメント(narration/insight)を生成できる
  • コメントが API レスポンスに含まれ、UI表示を阻害しない
  • コメント生成の入力(sql_result/graph_result/shape)と出力が追える

成果物:
コメント本文+生成根拠の最小トレース(run_id / providers / timings)


5) コメント差分を ChromaDB に保存(diff → upsert)

  • “前回コメント” と “今回コメント” の差分を作り
  • ChromaDB に idempotent に upsert できる
  • 保存形式(doc_id/natural_key/lang/meta)と検索キーが安定している
  • 失敗時も UI/レスポンスは維持(warnings/errors に寄せる)

成果物:
Chroma upsert の証跡(upserted/failed、doc_id、meta、source_hash)


6) 再問い合わせで反映確認(同じ質問→差分が効いている)

  • 同じ質問を再度投げたときに
    • コメントが更新されている(diff反映)
    • もしくは「差分なし」で NOP になっている(期待通り)
  • Chroma 参照の有無(top_k=0 のときは効かない等)を含め、設計通りの結果になる

成果物:
「1回目→保存→2回目」での差分反映結果(before/after、retrieval diag)


7) 失敗系の工程(本番で揉めないための最低限)

  • dev-portal 停止/タイムアウト時:nlq-dev は stub/エラー整形で落ちない
  • metabase 失敗時:カード更新失敗が切り分け可能
  • chroma 失敗時:コメント表示はできるが保存だけ失敗、など段階的劣化

成果物:
失敗時の reason_code / errors / 復旧手順の骨子に使えるログ


Comments

コメントを残す

メールアドレスが公開されることはありません。 が付いている欄は必須項目です