smallpond/logical/node.py [472:482]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        self.process_func = process_func

    def __str__(self) -> str:
        return super().__str__() + f", process_func={self.process_func}"

    @Node.task_factory
    def create_task(
        self,
        runtime_ctx: RuntimeContext,
        input_deps: List[Task],
        partition_infos: List[PartitionInfo],
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



smallpond/logical/node.py [628:638]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        self.process_func = process_func

    def __str__(self) -> str:
        return super().__str__() + f", process_func={self.process_func}"

    @Node.task_factory
    def create_task(
        self,
        runtime_ctx: RuntimeContext,
        input_deps: List[Task],
        partition_infos: List[PartitionInfo],
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -