name: pipe_with_cycle pipes: - name: a_source ty: Poller config: ty: PollerConfig output: Integer - name: mapper_a ty: Mapper upstreams: [ "mapper_c" ] config: ty: MapperConfig output: Integer - name: mapper_b ty: Mapper upstreams: [ "mapper_a" ] config: ty: MapperConfig output: Integer - name: mapper_c ty: Mapper upstreams: [ "mapper_b" ] config: ty: MapperConfig output: Integer