
    A'h                         d dl mZ d dlmZmZ d dlmZ d dlmZ d dlm	Z	 d dl
mZ d dlmZ dZd	e	fd
Zddde	deeeef      dedee   d	e	f
dZy)    )Mapping)datetimetimezone)Optional)BaseChannel)
Checkpoint)uuid6)MISSING   returnc            	          t        t        t        t        d            t	        j
                  t        j                        j                         i i i g       S )N	clock_seq)vidtschannel_valueschannel_versionsversions_seenpending_sends)	r   LATEST_VERSIONstrr	   r   nowr   utc	isoformat     b/home/kushmeetdev/Regenta/Chatbot/venv/lib/python3.12/site-packages/langgraph/pregel/checkpoint.pyempty_checkpointr       sD    
ur"#<<%//1 r   N)r   
checkpointchannelsstepr   c                ^   t        j                  t        j                        j	                         }|| d   }n2i }|D ]+  }|| d   vr||   j                         }|t        us'|||<   - t        t        ||xs t        t        |            || d   | d   | j                  dg             S )z+Create a checkpoint for the given channels.r   r   r   r   r   )r   r   r   r   r   r   r   )r   r   r   r   r   r!   r
   r   r   r   r	   get)r!   r"   r#   r   r   valueskr   s           r   create_checkpointr(      s     
hll	#	-	-	/B,- 	A
#566&&(Aq		 
+UT*+#$67 1 nn_b9 r   )collections.abcr   r   r   typingr   langgraph.channels.baser   langgraph.checkpoint.baser   langgraph.checkpoint.base.idr	   langgraph.constantsr
   r   r    r   intr(   r   r   r   <module>r0      sv    # '  / 0 . '	* 	" wsK/01 
 	 r   