iFndZddlZddlmZmZmZddlmZddlm Z ddl m Z m Z ddl mZGdd eZy) zLoop timer guard node executor.N)ListDictAny)Node)LoopTimerConfig)Message MessageRole) NodeExecutorcheZdZdZdZdedeedeefdZde e e e e fffdZ de d e de fd Zy ) LoopTimerNodeExecutoraTrack loop duration and emit output only after hitting the time limit. Supports two modes: 1. Standard Mode (passthrough=False): Suppresses input until time limit, then emits message 2. Terminal Gate Mode (passthrough=True): Acts as a sequential switch - Before limit: Pass input through unchanged - At limit: Emit configured message, suppress original input - After limit: Transparent gate, pass all subsequent messages through loop_timernodeinputsreturnc |jt}|td|jd|j }|j |ji}t j }d|vr ||d<d|d<|d}||z }|j|j|j} || k\} |jr | s3|jjd|jd|dd | dd |S|dsd |d<|jr||d<|jxsd |jd |jd} d||j|j|jd di} |jjd|jd|dd | ddtt j"| | gS|jjd|jd|dd|S| s3|jjd|jd|dd | ddgS|jr |ds||d<d |d<|jxsd |jd |jd} d||j|j|jddi} |jjd|jd|dd | ddtt j"| | gS)NzNode z! missing loop_timer configuration start_timeFemittedz LoopTimer z: z.1fzs / z&s (passthrough mode: forwarding input)TzTime limit reached ( )r ) elapsed_time max_duration duration_unit reset_on_emit passthroughz,s (passthrough mode: emitting limit message))rolecontentmetadataz&s (passthrough mode: transparent gate)zs (suppress downstream)z!s reached limit, releasing output) as_configr ValueErrorid _get_state setdefaulttime_convert_to_secondsrrr log_managerdebugrmessagerr ASSISTANT) selfrrconfigstate timer_state current_timerrmax_duration_seconds limit_reachedrrs V/Users/bowang/.openclaw/workspace/ChatDev/runtime/node/executor/loop_timer_executor.pyexecutezLoopTimerNodeExecutor.executesp0 >uTWWI-NOP P!&&tww3 yy{ { *(4K %%*K " . #j0  $77   !5!5  %(<<       &&  L+=TBVWZA[\;<  +)- I&''0RSV=WX() I    I(>(4K %!% I NN T%f&9&9%:!FrKs+% "":03H:LH:r2