func PrepareLoopingConveyor(cnv *conveyor.Conveyor) (*conveyor.Conveyor, error) {

    // Create a source executor, and add it to conveyor.
    // A pipeline may have only one source node
    gen := &NumberSource{