File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
libs/langgraph-checkpoint-mongodb/langgraph/checkpoint/mongodb Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -470,6 +470,16 @@ def delete_thread(
470470 # Delete all writes associated with the thread ID
471471 self .writes_collection .delete_many ({"thread_id" : thread_id })
472472
473+ async def aget_tuple (self , config : RunnableConfig ) -> Optional [CheckpointTuple ]:
474+ """Get a checkpoint tuple from the database.
475+
476+ Asynchronously wraps the blocking `self.get_tuple` method.
477+
478+ Args:
479+ config (RunnableConfig): The config to use for retrieving the checkpoint.
480+ """
481+ return await run_in_executor (None , self .get_tuple , config )
482+
473483 async def alist (
474484 self ,
475485 config : Optional [RunnableConfig ],
@@ -572,13 +582,3 @@ async def adelete_thread(
572582 thread_id: The thread ID whose checkpoints should be deleted.
573583 """
574584 return await run_in_executor (None , self .delete_thread , thread_id )
575-
576- async def aget_tuple (self , config : RunnableConfig ) -> Optional [CheckpointTuple ]:
577- """Get a checkpoint tuple from the database.
578-
579- Asynchronously wraps the blocking `self.get_tuple` method.
580-
581- Args:
582- config (RunnableConfig): The config to use for retrieving the checkpoint.
583- """
584- return await run_in_executor (None , self .get_tuple , config )
You can’t perform that action at this time.
0 commit comments