i fdZddlmZmZmZddlmZddlmZddl m Z m Z ddl m Z Gdde Zy ) z!Loop counter guard node executor.)ListDictAny)Node)LoopCounterConfig)Message MessageRole) NodeExecutorcTeZdZdZdZdedeedeefdZde e e e e fffdZ y) LoopCounterNodeExecutorzCTrack loop iterations and emit output only after hitting the limit. loop_counternodeinputsreturnc |jt}|td|jd|j }|j |jddi}|dxxdz cc<|d}||j kr;|jjd|jd|d|j d gS|jrd|d<|jxsd |j d }d ||j |jd i}|jjd|jd|d|j dttj||gS)NzNode z# missing loop_counter configurationcountrz LoopCounter z : iteration /z (suppress downstream)zLoop limit reached ()r )rmax reset_on_emitz reached limit, releasing output)rolecontentmetadata) as_configr ValueErrorid _get_state setdefaultmax_iterations log_managerdebugrmessagerr ASSISTANT) selfrrconfigstatecounterrrrs X/Users/bowang/.openclaw/workspace/ChatDev/runtime/node/executor/loop_counter_executor.pyexecutezLoopCounterNodeExecutor.executesp 12 >uTWWI-PQR R!""477WaL9A  6(( (    " "twwi|E7!Fr;s('"">03,Hl,Hr+