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

    gen := &NumberSource{
        ConcreteNodeExecutor: &conveyor.ConcreteNodeExecutor{Name: "number_generator"},
        CountLimit:           20,