
    mj                     D    d dl mZm Z  d dlmZmZ d dlmZ defdZddZy)	    )UTCdatetime)AgentOutboxRemoteAgentClientAgentRegistrationreturnc            	      $    t        ddddddd      S )Nzagent.local.alicezAlice laptopz0.1localzalice-laptoppython)	heartbeatr        tests/unit/test_remote_agent.pyregistrationr      s    0.%R`bjlz{{r   Nc                 V   t        | dz        }t        dt               |d      }	 |j                  ddddd	d
t	        dddddt
                    rJ |j                         dk(  sJ |j                         d   d   dk(  sJ 	 |j                          y # |j                          w xY w)Nzagent.sqlitezhttp://127.0.0.1:1   )timeout_secondszworker.alphazai.pipeline.taskr   zAI pipeline<   )display_namestale_after_secondsi        r   )tzinfoattempts)	r   r   r   emitr   r   sizependingclose)tmp_pathoutboxclients      r   8test_agent_outbox_retains_event_when_watcher_unreachabler#      s    N23F3\^V]^_F;;~/A;0=VXY'aB#FH 	H H {{}!!!~~":.!333s   AB B()r	   N)	r   r   worker_watcher.agentr   r   worker_watcher.modelsr   r   r#   r   r   r   <module>r&      s"    " ? 3|' |
r   