Method execute

runtime/node/executor/loop_timer_executor.py:25–136

(self, node: Node, inputs: List[Message])

    STATE_KEY = "loop_timer"

    def execute(self, node: Node, inputs: List[Message]) -> List[Message]:
        config = node.as_config(LoopTimerConfig)
        if config is None:
            raise ValueError(f"Node {node.id} missing loop_timer configuration")

        state = self._get_state()
        timer_state = state.setdefault(node.id, {})

        # Initialize timer on first execution
        current_time = time.time()
        if "start_time" not in timer_state:
            timer_state["start_time"] = current_time
            timer_state["emitted"] = False

        start_time = timer_state["start_time"]
        elapsed_time = current_time - start_time

        # Convert max_duration to seconds based on unit
        max_duration_seconds = self._convert_to_seconds(
            config.max_duration, config.duration_unit
        )

        # Check if time limit has been reached
        limit_reached = elapsed_time >= max_duration_seconds

        # Terminal Gate Mode (passthrough=True)
        if config.passthrough:
            if not limit_reached:
                # Before limit: pass input through unchanged
                self.log_manager.debug(
                    f"LoopTimer {node.id}: {elapsed_time:.1f}s / {max_duration_seconds:.1f}s "
                    f"(passthrough mode: forwarding input)"
                )
                return inputs
            elif not timer_state["emitted"]:
                # At limit: emit configured message, suppress original input
                timer_state["emitted"] = True
                if config.reset_on_emit:
                    timer_state["start_time"] = current_time

                content = (
                    config.message
                    or f"Time limit reached ({config.max_duration} {config.duration_unit})"
                )
                metadata = {
                    "loop_timer": {
                        "elapsed_time": elapsed_time,
                        "max_duration": config.max_duration,
                        "duration_unit": config.duration_unit,
                        "reset_on_emit": config.reset_on_emit,
                        "passthrough": True,
                    }
                }

                self.log_manager.debug(
                    f"LoopTimer {node.id}: {elapsed_time:.1f}s / {max_duration_seconds:.1f}s "
                    f"(passthrough mode: emitting limit message)"
                )