sqlite3.InterfaceError: bad parameter or other API misuse

[raphavtorres]

Scenario and error

I'm running multiple threads in my program. Two worked without any error, but one responded with

InterfaceError('bad parameter or other API misuse')Traceback (most recent call last):
...
sqlite3.InterfaceError: bad parameter or other API misuse

The error pointed to:
langgraph\pregel\__init__.py", line 889, in stream with SyncPregelLoop(...

langgraph\checkpoint\sqlite\__init__.py", line 222, in get_tuple cur.execute(

langgraph\pregel\loop.py", line 432, in __enter__ self.checkpointer.get_tuple(self.config) if self.checkpointer else None

Running Threads

executor = ThreadPoolExecutor(max_workers=10)


def sync_worker(req: RequestSchema):
    # Here we run diferent threads to the negotiations
    # the request is to chargingStation proxy endpoint
    data = requests.get(f'{req.station_address}informations/')
    chs_schedule_informations = data.json()
    print(f"\n\n \t\t THREAD: {threading.get_native_id()} \n\n")
    graph = get_graph(
        chs_information=chs_schedule_informations,
        car_information=req.car_information
    )

    thread_config = {"configurable": {"thread_id": threading.get_native_id()}}

    events = graph.stream(
        {
            "messages": [
                HumanMessage(content=prompt)
            ],
        },
        thread_config,
    )

    # Gathers and returns created events
    result = [s for s in events]
    result = []
    print("EVENTS RESULTS: ", result)
    return result


@router.post('/')
async def post(req: RequestSchema):
    loop = asyncio.get_event_loop()
    result = await loop.run_in_executor(executor, sync_worker, req)
    return {"result": result}  # Returns in a serialized format

System

langgraph==0.2.1
langgraph-checkpoint==1.0.2
langgraph-checkpoint-sqlite==1.0.0
langsmith==0.1.98

[nfcampos]

Hi, this has been fixed in latest release of langgraph-checkpoint-sqlite