Stops all running processors :return: None
(self)
| 1129 | return True |
| 1130 | |
| 1131 | def terminate(self): |
| 1132 | """ |
| 1133 | Stops all running processors |
| 1134 | :return: None |
| 1135 | """ |
| 1136 | for processor in self._processors.values(): |
| 1137 | Stats.decr('dag_processing.processes') |
| 1138 | processor.terminate() |
| 1139 | |
| 1140 | def end(self): |
| 1141 | """ |
no test coverage detected