fix(OMN-11994): handler_wiring psycopg2 list adaptation for text[] columns

src/omnibase_infra/runtime/auto_wiring/handler_wiring.py

@@ -805,9 +805,7 @@ def upsert(self, table: str, conflict_key: str, row: dict[str, object]) -> bool:
             )
             conflict_columns = ", ".join(f'"{key}"' for key in conflict_keys)
             adapted_row = {
-                key: psycopg2.extras.Json(value)
-                if isinstance(value, (dict, list))
-                else value
+                key: psycopg2.extras.Json(value) if isinstance(value, dict) else value
                 for key, value in row.items()
             }
             # table/conflict_key/cols validated by _TABLE_NAME_RE — not raw user input

tests/integration/runtime/test_projection_handler_db_injection_integration.py

@@ -12,12 +12,15 @@
 from __future__ import annotations
 
 import asyncio
+import sys
+import types
 from pathlib import Path
 from unittest.mock import MagicMock, patch
 
 import pytest
 
 from omnibase_infra.runtime.auto_wiring.handler_wiring import (
+    _build_sync_db_adapter,
     _make_projection_dispatch_callback,
     _read_db_io_tables,
 )
@@ -404,3 +407,63 @@ def handle(self, input_data: dict) -> dict:
 
     assert result is None
     assert call_count[0] == 0
+
+
+@pytest.mark.integration
+def test_sync_psycopg2_adapter_preserves_text_array_lists(
+    monkeypatch: pytest.MonkeyPatch,
+) -> None:
+    """The sync adapter must not JSON-wrap Postgres text[] values."""
+
+    captured_execute: dict[str, object] = {}
+
+    class FakeJson:
+        def __init__(self, value: object) -> None:
+            self.value = value
+
+    class FakeCursor:
+        def __enter__(self) -> FakeCursor:
+            return self
+
+        def __exit__(self, *args: object) -> None:
+            return None
+
+        def execute(self, sql: str, params: object) -> None:
+            captured_execute["sql"] = sql
+            captured_execute["params"] = params
+
+    class FakeConnection:
+        closed = False
+        autocommit = False
+
+        def cursor(self, *args: object, **kwargs: object) -> FakeCursor:
+            return FakeCursor()
+
+    fake_extras = types.SimpleNamespace(Json=FakeJson, RealDictCursor=object)
+    fake_psycopg2 = types.SimpleNamespace(
+        connect=lambda dsn: FakeConnection(),
+        extras=fake_extras,
+    )
+
+    monkeypatch.setitem(sys.modules, "psycopg2", fake_psycopg2)
+    monkeypatch.setitem(sys.modules, "psycopg2.extras", fake_extras)
+
+    adapter = _build_sync_db_adapter("postgresql://example")
+    result = adapter.upsert(
+        "swarm_runs",
+        "run_id",
+        {
+            "run_id": "run-1",
+            "models_used": ["qwen3", "gpt-5"],
+            "machines_used": ["worker-a", "worker-b"],
+            "metadata": {"source": "integration-test"},
+        },
+    )
+
+    assert result is True
+    params = captured_execute["params"]
+    assert isinstance(params, dict)
+    assert params["models_used"] == ["qwen3", "gpt-5"]
+    assert params["machines_used"] == ["worker-a", "worker-b"]
+    assert isinstance(params["metadata"], FakeJson)
+    assert params["metadata"].value == {"source": "integration-test"}