Method add_iterate

python/pathway/internals/parse_graph.py:156–180

Adds iterate operator. New scope is added to stack before calling iteration result. This scope is then preserved in IterateOperator node and removed from the stack. Args: body: specification of an iterated body function call_operator: iterate opereat

(
        self,
        body: FunctionSpec,
        call_operator: Callable[[operator.IterateOperator], T],
        iteration_limit: int | None = None,
    )

        return result

    def add_iterate(
        self,
        body: FunctionSpec,
        call_operator: Callable[[operator.IterateOperator], T],
        iteration_limit: int | None = None,
    ) -> T:
        """Adds iterate operator.

        New scope is added to stack before calling iteration result. This scope is then preserved
        in IterateOperator node and removed from the stack.

        Args:
            body: specification of an iterated body function
            call_operator: iterate opereator callback
        """

        def create_node(id: int) -> operator.IterateOperator:
            return operator.IterateOperator(body, id, iterate_scope, iteration_limit)

        def call_operator_in_scope(o: operator.IterateOperator) -> T:
            with iterate_scope:
                return call_operator(o)

        iterate_scope = self.new_scope()
        return self.add_operator(create_node, call_operator_in_scope)

    def add_error_log(self, global_log: bool = False) -> Table[ErrorLogSchema]:
        datasource = ErrorLogDataSource(schema=ErrorLogSchema)