/** * 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'] ); } } } } } } } } 追加開発 – Raqqa

追加開発

—

by

in Uncategorized

1) 現状の nlq-dev 構成（ツリーから読めること）

入口（API）

routers/nlq_plan.py：NLQ → plan を作る（現状ここが Router）
routers/nlq_execute.py：plan を実行（現状ここが Executor）
routers/nlq.py：たぶん統合エンドポイント（plan+execute or chat）
routers/history.py：履歴
routers/schema.py：スキーマ参照
routers/chroma.py, routers/package.py：Chroma/パッケージ系（既存資産）

コアサービス（今回の修正主戦場）

services/nlq_plan.py：plan 生成ロジック（LLM①含む可能性高）
services/nlq_stub.py：スタブ実装（開発用）
services/graph_client.py：DeciKG/Neo4j 側のクライアントになり得る
services/sql_guard.py, services/sql_normalize.py：SQL生成/実行前提のガード
services/llm_client.py：LLMラッパ
services/history_service.py：履歴永続化
services/schema_service.py：スキーマ参照（どこのスキーマか要確認）

データモデル

schemas/nlq.py, schemas/execute.py, schemas/history.py：Plan/Execute/HistoryのPydantic
SQL DDL：040_nlq_history.sql, 050_nlq_pipeline.sql, 060_nlq_history_artifacts.sql

2) 今回の議論（DeciKG優先）を入れるときの「修正点の当たり」

あなたの最新方針はこうでした：

数値だからSQLではない
Mermaid/概念モデルに載っている対象は優先的にDeciKG（Cypher）を見る
nlq-devは SQL/Cypher文を生成せず、QueryPlan(JSON) を生成して Route Executor が外部を叩く

これを既存構造に当てると、修正ポイントは主に 3箇所です。

A) Planのスキーマ＆生成（Router）

いま：services/nlq_plan.py が「SQL前提のplan」を作ってる可能性が高い
これから：planは route / preferred_source / concept_lookup / sql_params / cypher_params / merge.strategy を持つ必要あり
→ 変更対象：
schemas/nlq.py（Planモデル拡張）
services/nlq_plan.py（LLM①出力を QueryPlan に固定）
routers/nlq_plan.py（入出力更新）

B) 実行（Route Executor を中心に再編）

いま：routers/nlq_execute.py or services/nlq_stub.py が「SQL実行→結果→文章化」中心かも
これから：SqlExecutor / CypherExecutor / HybridExecutor / ParallelExecutor を実装し、graph_client.py と dev-portal 呼び出しをここへ集約
→ 変更対象：
services/graph_client.py（Cypher実行＋concept lookup が入る可能性）
新設 services/route_executor.py（または services/executors/*）
routers/nlq_execute.py（RouteExecutorを呼ぶだけに薄くする）
schemas/execute.py（SQL結果＋Graph結果＋統合結果を保持）

C) 履歴/成果物（history + artifacts）

いま：SQLだけ保存しているなら、routeやgraph結果の要約を保存できない
これから：最低でも route / plan / 外部呼び出し要約 / 片系失敗 を履歴に残す
→ 変更対象：
services/history_service.py
schemas/history.py
（必要なら）060_nlq_history_artifacts.sql の拡張

3) doc本文を見て「確定させたい観点」

次に貼ってくれる docs は、特にここを見たいです（ここが分かると修正が一気に確定します）。

現状の nlq_plan の出力フォーマット（Pydanticモデル）
nlq_execute が何を入力にして何を返しているか（SQL文を持ってる？）
graph_client.py は今どこまで実装済みか（Neo4j接続・Cypher実行・ダミー？）
dev-portal との接続口が既にあるか（URL/認証/エンドポイント）
history のスキーマ（plan/execute/answer/SQL/メタベースカード等をどう保存してるか）

4) 先に言っておく「たぶん要る作業」

docsを見て確定しますが、ほぼ確実に必要になるのは：

Planスキーマを QueryPlan v1.1 相当に差し替え（route＋preferred_source＋concept_lookup）
Executorを SQL単独前提から route分岐へ
sql_guard/sql_normalize は “SQL_ONLY” と “HybridのSQLフェーズ” でのみ使う（常時適用しない）
executeの返却を (sql_result, graph_result, merged_result, narration) に分離

Comments

コメントを残すコメントをキャンセル