Similarity search with distance filter failed: (psycopg.errors.UndefinedColumn) column "product_ids" does not exist

[esseti]

Hello,

I've a PGVectorStore where i've instered Documents in this content:

id: fff86dca-918c-421d-9124-333e8ac3bf8a
metadata: {
  "scope": "company",
  "title": "data_test.txt",
  "filename": "data_test.txt",
  "document_id": "31927",
  "product_ids": [],
  "start_index": 0,
  "source_document_id": "31927"
}
Lorem ipsum dolor sit amet, consectetur adipiscing elit. Vestibulum in justo sodales, accumsan orci quis, malesuada ligula. Ut dapibus lectus a eros efficitur, at convallis  … (+510 chars)

Now, i'm performing a query of this type

all_results = vector_store.similarity_search_with_score(
            query=query,
            k=k,
            filter=filter,
        )

where the actual content is this

Performing similarity search with query Qual è l'architettura di conservazione dei dati e dove si trovano fisicamente i server? , filter={'product_ids': {'$in': [34]}} and k=50

i get this as an error

2026-05-14 15:16:54.281 | [14/May/2026 13:16:54] ERROR [4699.ai.rag:504]  Similarity search with distance filter failed: (psycopg.errors.UndefinedColumn) column "product_ids" does not exist
2026-05-14 15:16:54.281 | LINE 2:         FROM "public"."rag_company_11" WHERE product_ids = A...
2026-05-14 15:16:54.281 |                                                      ^
2026-05-14 15:16:54.281 | [SQL: SELECT "langchain_id", "content", "embedding", "langchain_metadata", cosine_distance("embedding", %(query_embedding)s) as distance
2026-05-14 15:16:54.281 |         FROM "public"."rag_company_11" WHERE product_ids = ANY(%(product_ids_in_bc347a3b)s) ORDER BY "embedding" <=> %(query_embedding)s LIMIT %(dense_limit)s;
2026-05-14 15:16:54.281 |         ]
2026-05-14 15:16:54.281 | [parameters: {'query_embedding': '[-0.004596710205078125, 0.01456451416015625, 0.0518798828125, 0.012725830078125, 0.0634765625, 0.03546142578125, -0.046844482421875, -0.0014133453369 ... (30701 characters truncated) ... 34942626953125, 0.002788543701171875, -0.0008635520935058594, -0.0179290771484375, -0.034637451171875, 0.002643585205078125, -0.00012230873107910156]', 'product_ids_in_bc347a3b': [34], 'dense_limit': 50}]
2026-05-14 15:16:54.281 | (Background on this error at: https://sqlalche.me/e/20/f405)
2026-05-14 15:16:54.281 | Traceback (most recent call last):
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1967, in _exec_single_context
2026-05-14 15:16:54.281 |     self.dialect.do_execute(
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 952, in do_execute
2026-05-14 15:16:54.281 |     cursor.execute(statement, parameters)
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/dialects/postgresql/psycopg.py", line 673, in execute
2026-05-14 15:16:54.281 |     result = self.await_(self._cursor.execute(query, params, **kw))
2026-05-14 15:16:54.281 |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 132, in await_only
2026-05-14 15:16:54.281 |     return current.parent.switch(awaitable)  # type: ignore[no-any-return,attr-defined] # noqa: E501
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 196, in greenlet_spawn
2026-05-14 15:16:54.281 |     value = await result
2026-05-14 15:16:54.281 |             ^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/psycopg/cursor_async.py", line 117, in execute
2026-05-14 15:16:54.281 |     raise ex.with_traceback(None)
2026-05-14 15:16:54.281 | psycopg.errors.UndefinedColumn: column "product_ids" does not exist
2026-05-14 15:16:54.281 | LINE 2:         FROM "public"."rag_company_11" WHERE product_ids = A...
2026-05-14 15:16:54.281 |                                                      ^
2026-05-14 15:16:54.281 | 
2026-05-14 15:16:54.281 | The above exception was the direct cause of the following exception:
2026-05-14 15:16:54.281 | 
2026-05-14 15:16:54.281 | Traceback (most recent call last):
2026-05-14 15:16:54.281 |   File "/opt/src/ai/rag.py", line 491, in similarity_search_with_distance_filter
2026-05-14 15:16:54.281 |     all_results = vector_store.similarity_search_with_score(
2026-05-14 15:16:54.281 |                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/langchain_postgres/v2/vectorstores.py", line 714, in similarity_search_with_score
2026-05-14 15:16:54.281 |     return self._engine._run_as_sync(
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/langchain_postgres/v2/engine.py", line 131, in _run_as_sync
2026-05-14 15:16:54.281 |     return asyncio.run_coroutine_threadsafe(coro, self._loop).result()  # type: ignore[arg-type]
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/usr/local/lib/python3.12/concurrent/futures/_base.py", line 456, in result
2026-05-14 15:16:54.281 |     return self.__get_result()
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/usr/local/lib/python3.12/concurrent/futures/_base.py", line 401, in __get_result
2026-05-14 15:16:54.281 |     raise self._exception
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py", line 738, in asimilarity_search_with_score
2026-05-14 15:16:54.281 |     docs = await self.asimilarity_search_with_score_by_vector(
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py", line 765, in asimilarity_search_with_score_by_vector
2026-05-14 15:16:54.281 |     results = await self.__query_collection(
2026-05-14 15:16:54.281 |               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py", line 636, in __query_collection
2026-05-14 15:16:54.281 |     result = await conn.execute(text(dense_query_stmt), param_dict)
2026-05-14 15:16:54.281 |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/ext/asyncio/engine.py", line 659, in execute
2026-05-14 15:16:54.281 |     result = await greenlet_spawn(
2026-05-14 15:16:54.281 |              ^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 201, in greenlet_spawn
2026-05-14 15:16:54.281 |     result = context.throw(*sys.exc_info())
2026-05-14 15:16:54.281 |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1419, in execute
2026-05-14 15:16:54.281 |     return meth(
2026-05-14 15:16:54.281 |            ^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", line 527, in _execute_on_connection
2026-05-14 15:16:54.281 |     return connection._execute_clauseelement(
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1641, in _execute_clauseelement
2026-05-14 15:16:54.281 |     ret = self._execute_context(
2026-05-14 15:16:54.281 |           ^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1846, in _execute_context
2026-05-14 15:16:54.281 |     return self._exec_single_context(
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1986, in _exec_single_context
2026-05-14 15:16:54.281 |     self._handle_dbapi_exception(
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2363, in _handle_dbapi_exception
2026-05-14 15:16:54.281 |     raise sqlalchemy_exception.with_traceback(exc_info[2]) from e
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1967, in _exec_single_context
2026-05-14 15:16:54.281 |     self.dialect.do_execute(
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 952, in do_execute
2026-05-14 15:16:54.281 |     cursor.execute(statement, parameters)
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/dialects/postgresql/psycopg.py", line 673, in execute
2026-05-14 15:16:54.281 |     result = self.await_(self._cursor.execute(query, params, **kw))
2026-05-14 15:16:54.281 |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 132, in await_only
2026-05-14 15:16:54.281 |     return current.parent.switch(awaitable)  # type: ignore[no-any-return,attr-defined] # noqa: E501
2026-05-14 15:16:54.281 |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 196, in greenlet_spawn
2026-05-14 15:16:54.281 |     value = await result
2026-05-14 15:16:54.281 |             ^^^^^^^^^^^^
2026-05-14 15:16:54.281 |   File "/opt/.venv/lib/python3.12/site-packages/psycopg/cursor_async.py", line 117, in execute
2026-05-14 15:16:54.281 |     raise ex.with_traceback(None)
2026-05-14 15:16:54.281 | sqlalchemy.exc.ProgrammingError: (psycopg.errors.UndefinedColumn) column "product_ids" does not exist
2026-05-14 15:16:54.281 | LINE 2:         FROM "public"."rag_company_11" WHERE product_ids = A...
2026-05-14 15:16:54.281 |                                                      ^
2026-05-14 15:16:54.281 | [SQL: SELECT "langchain_id", "content", "embedding", "langchain_metadata", cosine_distance("embedding", %(query_embedding)s) as distance
2026-05-14 15:16:54.281 |         FROM "public"."rag_company_11" WHERE product_ids = ANY(%(product_ids_in_bc347a3b)s) ORDER BY "embedding" <=> %(query_embedding)s LIMIT %(dense_limit)s;
2026-05-14 15:16:54.281 |         ]
2026-05-14 15:16:54.281 | [parameters: {'query_embedding': '[-0.004596710205078125, 0.01456451416015625, 0.0518798828125, 0.012725830078125, 0.0634765625, 0.03546142578125, -0.046844482421875, -0.0014133453369 ... (30701 characters truncated) ... 34942626953125, 0.002788543701171875, -0.0008635520935058594, -0.0179290771484375, -0.034637451171875, 0.002643585205078125, -0.00012230873107910156]', 'product_ids_in_bc347a3b': [34], 'dense_limit': 50}]
2026-05-14 15:16:54.281 | (Background on this error at: https://sqlalche.me/e/20/f405)

Where do i make the mistake?

[esseti]

To replicate the issue:

from langchain_postgres import PGEngine, PGVectorStore
from langchain_openai import OpenAIEmbeddings
from langchain_core.documents import Document

DSN = "DEFINE STRING HERE FOR THE CONNECTION" #ex 'postgresql+psycopg://postgres:@localhost:5433/db_rag'

engine = PGEngine.from_connection_string(url=DSN)
engine.init_vectorstore_table(table_name="my_table_test_error", vector_size=1536)
vs = PGVectorStore.create_sync(
    engine=engine,
    embedding_service=OpenAIEmbeddings(model="text-embedding-3-small"),
    table_name="my_table_test_error",
)

# Add a document with metadata
vs.add_documents([
    Document(page_content="hello", metadata={"scope": "company", "product_ids": [34]})
])

# Try to filter by a JSONB metadata key
vs.similarity_search_with_score("hello", k=5, filter={"product_ids": {"$in": [34]}})

you get a long stacktrace that boils down to this

ProgrammingError: (psycopg.errors.UndefinedColumn) column "product_ids" does not exist
LINE 2:         FROM "public"."my_table_test_error" WHERE product_id...
                                                          ^
[SQL: SELECT "langchain_id", "content", "embedding", "langchain_metadata", cosine_distance("embedding", %(query_embedding)s) as distance
        FROM "public"."my_table_test_error" WHERE product_ids = ANY(%(product_ids_in_8b8cc9ee)s) ORDER BY "embedding" <=> %(query_embedding)s LIMIT %(dense_limit)s;
        ]
[parameters: {'query_embedding': '[0.016754150390625, -0.055755615234375, 0.005672454833984375, 0.06622314453125, 0.008941650390625, -0.047332763671875, -0.028167724609375, 0.06109619 ... (30817 characters truncated) ... 75, 0.004680633544921875, 0.0119171142578125, 0.01268768310546875, 0.006687164306640625, -0.01116943359375, -0.0159759521484375, -0.0174407958984375]', 'product_ids_in_8b8cc9ee': [34], 'dense_limit': 5}]
(Background on this error at: https://sqlalche.me/e/20/f405)

[esseti]

We were on version 0.0.16 and 0.0.17 should work BUT i recevie now this error

---------------------------------------------------------------------------
InvalidTextRepresentation                 Traceback (most recent call last)
File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1967, in Connection._exec_single_context(self, dialect, context, statement, parameters)
   1966     if not evt_handled:
-> 1967         self.dialect.do_execute(
   1968             cursor, str_statement, effective_parameters, context
   1969         )
   1971 if self._has_events or self.engine._has_events:

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/default.py:952, in DefaultDialect.do_execute(self, cursor, statement, parameters, context)
    951 def do_execute(self, cursor, statement, parameters, context=None):
--> 952     cursor.execute(statement, parameters)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/dialects/postgresql/psycopg.py:673, in AsyncAdapt_psycopg_cursor.execute(self, query, params, **kw)
    672 def execute(self, query, params=None, **kw):
--> 673     result = self.await_(self._cursor.execute(query, params, **kw))
    674     # sqlalchemy result is not async, so need to pull all rows here

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py:132, in await_only(awaitable)
    128 # returns the control to the driver greenlet passing it
    129 # a coroutine to run. Once the awaitable is done, the driver greenlet
    130 # switches back to this greenlet with the result of awaitable that is
    131 # then returned to the caller (or raised as error)
--> 132 return current.parent.switch(awaitable)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py:196, in greenlet_spawn(fn, _require_await, *args, **kwargs)
    193 try:
    194     # wait for a coroutine from await_only and then return its
    195     # result back to it.
--> 196     value = await result
    197 except BaseException:
    198     # this allows an exception to be raised within
    199     # the moderated greenlet so that it can continue
    200     # its expected flow.

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/psycopg/cursor_async.py:117, in AsyncCursor.execute(self, query, params, prepare, binary)
    116 except e._NO_TRACEBACK as ex:
--> 117     raise ex.with_traceback(None)
    118 return self

InvalidTextRepresentation: invalid input syntax for type integer: "[34]"

The above exception was the direct cause of the following exception:

DataError                                 Traceback (most recent call last)
Cell In[30], line 1
----> 1 vs.similarity_search_with_relevance_scores("hello", k=5, filter={"product_ids": {"$in": [int(34)]}})

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_core/vectorstores/base.py:529, in VectorStore.similarity_search_with_relevance_scores(self, query, k, **kwargs)
    512 """Return docs and relevance scores in the range `[0, 1]`.
    513 
    514 `0` is dissimilar, `1` is most similar.
   (...)
    525     List of tuples of `(doc, similarity_score)`.
    526 """
    527 score_threshold = kwargs.pop("score_threshold", None)
--> 529 docs_and_similarities = self._similarity_search_with_relevance_scores(
    530     query, k=k, **kwargs
    531 )
    532 if any(
    533     similarity < 0.0 or similarity > 1.0
    534     for _, similarity in docs_and_similarities
    535 ):
    536     warnings.warn(
    537         "Relevance scores must be between"
    538         f" 0 and 1, got {docs_and_similarities}",
    539         stacklevel=2,
    540     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_core/vectorstores/base.py:475, in VectorStore._similarity_search_with_relevance_scores(self, query, k, **kwargs)
    456 """Default similarity search with relevance scores.
    457 
    458 Modify if necessary in subclass.
   (...)
    472     List of tuples of `(doc, similarity_score)`
    473 """
    474 relevance_score_fn = self._select_relevance_score_fn()
--> 475 docs_and_scores = self.similarity_search_with_score(query, k, **kwargs)
    476 return [(doc, relevance_score_fn(score)) for doc, score in docs_and_scores]

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_postgres/v2/vectorstores.py:762, in PGVectorStore.similarity_search_with_score(self, query, k, filter, **kwargs)
    754 def similarity_search_with_score(
    755     self,
    756     query: str,
   (...)
    759     **kwargs: Any,
    760 ) -> list[tuple[Document, float]]:
    761     """Return docs and distance scores selected by similarity search on query."""
--> 762     return self._engine._run_as_sync(
    763         self.__vs.asimilarity_search_with_score(query, k, filter, **kwargs)
    764     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_postgres/v2/engine.py:131, in PGEngine._run_as_sync(self, coro)
    127 if not self._loop:
    128     raise Exception(
    129         "Engine was initialized without a background loop and cannot call sync methods."
    130     )
--> 131 return asyncio.run_coroutine_threadsafe(coro, self._loop).result()

File /opt/homebrew/Cellar/python@3.12/3.12.13/Frameworks/Python.framework/Versions/3.12/lib/python3.12/concurrent/futures/_base.py:456, in Future.result(self, timeout)
    454     raise CancelledError()
    455 elif self._state == FINISHED:
--> 456     return self.__get_result()
    457 else:
    458     raise TimeoutError()

File /opt/homebrew/Cellar/python@3.12/3.12.13/Frameworks/Python.framework/Versions/3.12/lib/python3.12/concurrent/futures/_base.py:401, in Future.__get_result(self)
    399 if self._exception:
    400     try:
--> 401         raise self._exception
    402     finally:
    403         # Break a reference cycle with the exception in self._exception
    404         self = None

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py:827, in AsyncPGVectorStore.asimilarity_search_with_score(self, query, k, filter, **kwargs)
    824     hybrid_search_config.fts_query = query
    825     kwargs["hybrid_search_config"] = hybrid_search_config
--> 827 docs = await self.asimilarity_search_with_score_by_vector(
    828     embedding=embedding, k=k, filter=filter, **kwargs
    829 )
    830 return docs

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py:854, in AsyncPGVectorStore.asimilarity_search_with_score_by_vector(self, embedding, k, filter, **kwargs)
    846 async def asimilarity_search_with_score_by_vector(
    847     self,
    848     embedding: list[float],
   (...)
    851     **kwargs: Any,
    852 ) -> list[tuple[Document, float]]:
    853     """Return docs and distance scores selected by vector similarity search."""
--> 854     results = await self.__query_collection(
    855         embedding=embedding, k=k, filter=filter, **kwargs
    856     )
    858     documents_with_scores = []
    859     for row in results:

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/langchain_postgres/v2/async_vectorstore.py:692, in AsyncPGVectorStore.__query_collection(self, embedding, k, filter, **kwargs)
    690 else:
    691     async with self.engine.connect() as conn:
--> 692         result = await conn.execute(text(dense_query_stmt), param_dict)
    693         result_map = result.mappings()
    694         dense_results = result_map.fetchall()

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/ext/asyncio/engine.py:659, in AsyncConnection.execute(self, statement, parameters, execution_options)
    621 async def execute(
    622     self,
    623     statement: Executable,
   (...)
    626     execution_options: Optional[CoreExecuteOptionsParameter] = None,
    627 ) -> CursorResult[Any]:
    628     r"""Executes a SQL statement construct and return a buffered
    629     :class:`_engine.Result`.
    630 
   (...)
    657 
    658     """
--> 659     result = await greenlet_spawn(
    660         self._proxied.execute,
    661         statement,
    662         parameters,
    663         execution_options=execution_options,
    664         _require_await=True,
    665     )
    666     return await _ensure_sync_result(result, self.execute)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py:201, in greenlet_spawn(fn, _require_await, *args, **kwargs)
    196     value = await result
    197 except BaseException:
    198     # this allows an exception to be raised within
    199     # the moderated greenlet so that it can continue
    200     # its expected flow.
--> 201     result = context.throw(*sys.exc_info())
    202 else:
    203     result = context.switch(value)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1419, in Connection.execute(self, statement, parameters, execution_options)
   1417     raise exc.ObjectNotExecutableError(statement) from err
   1418 else:
-> 1419     return meth(
   1420         self,
   1421         distilled_parameters,
   1422         execution_options or NO_OPTIONS,
   1423     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/sql/elements.py:527, in ClauseElement._execute_on_connection(self, connection, distilled_params, execution_options)
    525     if TYPE_CHECKING:
    526         assert isinstance(self, Executable)
--> 527     return connection._execute_clauseelement(
    528         self, distilled_params, execution_options
    529     )
    530 else:
    531     raise exc.ObjectNotExecutableError(self)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1641, in Connection._execute_clauseelement(self, elem, distilled_parameters, execution_options)
   1629 compiled_cache: Optional[CompiledCacheType] = execution_options.get(
   1630     "compiled_cache", self.engine._compiled_cache
   1631 )
   1633 compiled_sql, extracted_params, cache_hit = elem._compile_w_cache(
   1634     dialect=dialect,
   1635     compiled_cache=compiled_cache,
   (...)
   1639     linting=self.dialect.compiler_linting | compiler.WARN_LINTING,
   1640 )
-> 1641 ret = self._execute_context(
   1642     dialect,
   1643     dialect.execution_ctx_cls._init_compiled,
   1644     compiled_sql,
   1645     distilled_parameters,
   1646     execution_options,
   1647     compiled_sql,
   1648     distilled_parameters,
   1649     elem,
   1650     extracted_params,
   1651     cache_hit=cache_hit,
   1652 )
   1653 if has_events:
   1654     self.dispatch.after_execute(
   1655         self,
   1656         elem,
   (...)
   1660         ret,
   1661     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1846, in Connection._execute_context(self, dialect, constructor, statement, parameters, execution_options, *args, **kw)
   1844     return self._exec_insertmany_context(dialect, context)
   1845 else:
-> 1846     return self._exec_single_context(
   1847         dialect, context, statement, parameters
   1848     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1986, in Connection._exec_single_context(self, dialect, context, statement, parameters)
   1983     result = context._setup_result_proxy()
   1985 except BaseException as e:
-> 1986     self._handle_dbapi_exception(
   1987         e, str_statement, effective_parameters, cursor, context
   1988     )
   1990 return result

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:2363, in Connection._handle_dbapi_exception(self, e, statement, parameters, cursor, context, is_sub_exec)
   2361 elif should_wrap:
   2362     assert sqlalchemy_exception is not None
-> 2363     raise sqlalchemy_exception.with_traceback(exc_info[2]) from e
   2364 else:
   2365     assert exc_info[1] is not None

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/base.py:1967, in Connection._exec_single_context(self, dialect, context, statement, parameters)
   1965                 break
   1966     if not evt_handled:
-> 1967         self.dialect.do_execute(
   1968             cursor, str_statement, effective_parameters, context
   1969         )
   1971 if self._has_events or self.engine._has_events:
   1972     self.dispatch.after_cursor_execute(
   1973         self,
   1974         cursor,
   (...)
   1978         context.executemany,
   1979     )

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/engine/default.py:952, in DefaultDialect.do_execute(self, cursor, statement, parameters, context)
    951 def do_execute(self, cursor, statement, parameters, context=None):
--> 952     cursor.execute(statement, parameters)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/dialects/postgresql/psycopg.py:673, in AsyncAdapt_psycopg_cursor.execute(self, query, params, **kw)
    672 def execute(self, query, params=None, **kw):
--> 673     result = self.await_(self._cursor.execute(query, params, **kw))
    674     # sqlalchemy result is not async, so need to pull all rows here
    675     res = self._cursor.pgresult

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py:132, in await_only(awaitable)
    123     raise exc.MissingGreenlet(
    124         "greenlet_spawn has not been called; can't call await_only() "
    125         "here. Was IO attempted in an unexpected place?"
    126     )
    128 # returns the control to the driver greenlet passing it
    129 # a coroutine to run. Once the awaitable is done, the driver greenlet
    130 # switches back to this greenlet with the result of awaitable that is
    131 # then returned to the caller (or raised as error)
--> 132 return current.parent.switch(awaitable)

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py:196, in greenlet_spawn(fn, _require_await, *args, **kwargs)
    192 switch_occurred = True
    193 try:
    194     # wait for a coroutine from await_only and then return its
    195     # result back to it.
--> 196     value = await result
    197 except BaseException:
    198     # this allows an exception to be raised within
    199     # the moderated greenlet so that it can continue
    200     # its expected flow.
    201     result = context.throw(*sys.exc_info())

File ~/.virtualenvs/checksmate/lib/python3.12/site-packages/psycopg/cursor_async.py:117, in AsyncCursor.execute(self, query, params, prepare, binary)
    113         await self._conn.wait(
    114             self._execute_gen(query, params, prepare=prepare, binary=binary)
    115         )
    116 except e._NO_TRACEBACK as ex:
--> 117     raise ex.with_traceback(None)
    118 return self

DataError: (psycopg.errors.InvalidTextRepresentation) invalid input syntax for type integer: "[34]"
[SQL: SELECT "langchain_id", "content", "embedding", "langchain_metadata", cosine_distance("embedding", %(query_embedding)s) as distance
        FROM "public"."my_table_test_error" WHERE (langchain_metadata->>'product_ids')::INTEGER = ANY(%(product_ids_in_d01fbcc8)s) ORDER BY "embedding" <=> %(query_embedding)s LIMIT %(dense_limit)s;
        ]
[parameters: {'query_embedding': '[0.016754150390625, -0.055755615234375, 0.005672454833984375, 0.06622314453125, 0.008941650390625, -0.047332763671875, -0.028167724609375, 0.06109619 ... (30817 characters truncated) ... 75, 0.004680633544921875, 0.0119171142578125, 0.01268768310546875, 0.006687164306640625, -0.01116943359375, -0.0159759521484375, -0.0174407958984375]', 'product_ids_in_d01fbcc8': [34], 'dense_limit': 5}]
(Background on this error at: https://sqlalche.me/e/20/9h9h)