(self, *pipes)
| 114 | return pl |
| 115 | |
| 116 | def _add_pipes(self, *pipes): |
| 117 | # type: (*Pipe) -> Set[Pipe] |
| 118 | pl = set() |
| 119 | for p in pipes: |
| 120 | pl |= self.get_pipe_list(p) |
| 121 | pl -= self.active_pipes |
| 122 | for q in pl: |
| 123 | self.add_one_pipe(q) |
| 124 | return pl |
| 125 | |
| 126 | def run(self): |
| 127 | # type: () -> None |
no test coverage detected